diff options
| author | Alan Conway <aconway@apache.org> | 2012-03-05 21:31:58 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-03-05 21:31:58 +0000 |
| commit | 2629c625a302ee4dd98e10173407c0c90aa8def1 (patch) | |
| tree | 344025a92443736c33815155ee0dc54fbfab6fa3 /cpp/src/qpid | |
| parent | 9dd33c8c3e6f32b14af2b0fb5a89c408fb8796bd (diff) | |
| download | qpid-python-2629c625a302ee4dd98e10173407c0c90aa8def1.tar.gz | |
QPID-3603: Initial documentation for the new HA plug-in.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1297234 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid')
| -rw-r--r-- | cpp/src/qpid/ha/BrokerReplicator.cpp | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/ha/BrokerReplicator.cpp b/cpp/src/qpid/ha/BrokerReplicator.cpp index 85b97e7e3e..609a3378ad 100644 --- a/cpp/src/qpid/ha/BrokerReplicator.cpp +++ b/cpp/src/qpid/ha/BrokerReplicator.cpp @@ -113,15 +113,15 @@ template <class T> bool match(Variant::Map& schema) { return T::match(schema[CLASS_NAME], schema[PACKAGE_NAME]); } -enum ReplicateLevel { RL_NONE=0, RL_CONFIGURATION, RL_MESSAGES }; +enum ReplicateLevel { RL_NONE=0, RL_CONFIGURATION, RL_ALL }; const string S_NONE="none"; const string S_CONFIGURATION="configuration"; -const string S_MESSAGES="messages"; +const string S_ALL="all"; ReplicateLevel replicateLevel(const string& level) { if (level == S_NONE) return RL_NONE; if (level == S_CONFIGURATION) return RL_CONFIGURATION; - if (level == S_MESSAGES) return RL_MESSAGES; + if (level == S_ALL) return RL_ALL; throw Exception("Invalid value for "+QPID_REPLICATE+": "+level); } @@ -491,7 +491,7 @@ void BrokerReplicator::doResponseBind(Variant::Map& values) { } void BrokerReplicator::startQueueReplicator(const boost::shared_ptr<Queue>& queue) { - if (replicateLevel(queue->getSettings()) == RL_MESSAGES) { + if (replicateLevel(queue->getSettings()) == RL_ALL) { boost::shared_ptr<QueueReplicator> qr(new QueueReplicator(queue, link)); broker.getExchanges().registerExchange(qr); qr->activate(); |
