summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Broker.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2012-11-14 16:04:28 +0000
committerAlan Conway <aconway@apache.org>2012-11-14 16:04:28 +0000
commit2ec69aa47fef0acbcd629db7f5a9d1e399f179b0 (patch)
tree842cb1b34889612a60bf0b684a0fbf732d1197dc /cpp/src/qpid/broker/Broker.cpp
parent455df807ae7dbf902e69de1a69f61575a74e2d0b (diff)
downloadqpid-python-2ec69aa47fef0acbcd629db7f5a9d1e399f179b0.tar.gz
QPID-4401: Revert: HA bindings for QMF exchanges not replicated.
This reverts r1403946: There was a problem with this, for example if I bind a queue Q to receive broker events. On the backup, Q will receive double events: from the replicating subscription to the primary and events generated locally in the backup broker. That can cause the backup to generate "invalid position" errors and shut down. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1409243 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Broker.cpp')
-rw-r--r--cpp/src/qpid/broker/Broker.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp
index 96de6998b0..96f88da8ea 100644
--- a/cpp/src/qpid/broker/Broker.cpp
+++ b/cpp/src/qpid/broker/Broker.cpp
@@ -319,9 +319,9 @@ Broker::Broker(const Broker::Options& conf) :
std::string qmfDirect("qmf.default.direct");
std::pair<Exchange::shared_ptr, bool> topicPair(
- exchanges.declare(qmfTopic, ManagementTopicExchange::typeName, false));
+ exchanges.declare(qmfTopic, ManagementTopicExchange::typeName, false, noReplicateArgs()));
std::pair<Exchange::shared_ptr, bool> directPair(
- exchanges.declare(qmfDirect, ManagementDirectExchange::typeName, false));
+ exchanges.declare(qmfDirect, ManagementDirectExchange::typeName, false, noReplicateArgs()));
boost::dynamic_pointer_cast<ManagementDirectExchange>(directPair.first)->setManagmentAgent(managementAgent.get(), 2);
boost::dynamic_pointer_cast<ManagementTopicExchange>(topicPair.first)->setManagmentAgent(managementAgent.get(), 2);