diff options
| author | Alan Conway <aconway@apache.org> | 2012-11-14 16:04:28 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-11-14 16:04:28 +0000 |
| commit | 2ec69aa47fef0acbcd629db7f5a9d1e399f179b0 (patch) | |
| tree | 842cb1b34889612a60bf0b684a0fbf732d1197dc /cpp/src/qpid/broker/Broker.cpp | |
| parent | 455df807ae7dbf902e69de1a69f61575a74e2d0b (diff) | |
| download | qpid-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.cpp | 4 |
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); |
