diff options
Diffstat (limited to 'cpp/src/qpid/cluster/ClusterPlugin.cpp')
-rw-r--r-- | cpp/src/qpid/cluster/ClusterPlugin.cpp | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/cpp/src/qpid/cluster/ClusterPlugin.cpp b/cpp/src/qpid/cluster/ClusterPlugin.cpp index 79c34d6873..2a3df8f465 100644 --- a/cpp/src/qpid/cluster/ClusterPlugin.cpp +++ b/cpp/src/qpid/cluster/ClusterPlugin.cpp @@ -21,7 +21,7 @@ #include "qpid/cluster/Cluster.h" #include "qpid/cluster/ConnectionCodec.h" -#include "qpid/cluster/DumpClient.h" +#include "qpid/cluster/UpdateClient.h" #include "qpid/broker/Broker.h" #include "qpid/Plugin.h" @@ -87,43 +87,43 @@ struct ClusterOptions : public Options { } }; -struct DumpClientIdAllocator : management::IdAllocator +struct UpdateClientIdAllocator : management::IdAllocator { qpid::sys::AtomicValue<uint64_t> sequence; - DumpClientIdAllocator() : sequence(0x4000000000000000LL) {} + UpdateClientIdAllocator() : sequence(0x4000000000000000LL) {} uint64_t getIdFor(management::Manageable* m) { - if (isDumpQueue(m) || isDumpExchange(m) || isDumpSession(m) || isDumpBinding(m)) { + if (isUpdateQueue(m) || isUpdateExchange(m) || isUpdateSession(m) || isUpdateBinding(m)) { return ++sequence; } else { return 0; } } - bool isDumpQueue(management::Manageable* manageable) + bool isUpdateQueue(management::Manageable* manageable) { qpid::broker::Queue* queue = dynamic_cast<qpid::broker::Queue*>(manageable); - return queue && queue->getName() == DumpClient::DUMP; + return queue && queue->getName() == UpdateClient::UPDATE; } - bool isDumpExchange(management::Manageable* manageable) + bool isUpdateExchange(management::Manageable* manageable) { qpid::broker::Exchange* exchange = dynamic_cast<qpid::broker::Exchange*>(manageable); - return exchange && exchange->getName() == DumpClient::DUMP; + return exchange && exchange->getName() == UpdateClient::UPDATE; } - bool isDumpSession(management::Manageable* manageable) + bool isUpdateSession(management::Manageable* manageable) { broker::SessionState* session = dynamic_cast<broker::SessionState*>(manageable); - return session && session->getId().getName() == DumpClient::DUMP; + return session && session->getId().getName() == UpdateClient::UPDATE; } - bool isDumpBinding(management::Manageable* manageable) + bool isUpdateBinding(management::Manageable* manageable) { broker::Exchange::Binding* binding = dynamic_cast<broker::Exchange::Binding*>(manageable); - return binding && binding->queue->getName() == DumpClient::DUMP; + return binding && binding->queue->getName() == UpdateClient::UPDATE; } }; @@ -155,7 +155,7 @@ struct ClusterPlugin : public Plugin { broker->getExchanges().registerExchange(cluster->getFailoverExchange()); ManagementBroker* mgmt = dynamic_cast<ManagementBroker*>(ManagementAgent::Singleton::getInstance()); if (mgmt) { - std::auto_ptr<IdAllocator> allocator(new DumpClientIdAllocator()); + std::auto_ptr<IdAllocator> allocator(new UpdateClientIdAllocator()); mgmt->setAllocator(allocator); } } |