summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/cluster/UpdateClient.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2011-08-09 20:19:54 +0000
committerGordon Sim <gsim@apache.org>2011-08-09 20:19:54 +0000
commit32c07273359d3c0a469d8a32ec9a1862de85ed0b (patch)
tree5e840ccf56acc5fdc52a520d6959610e2855d575 /cpp/src/qpid/cluster/UpdateClient.cpp
parent33d54530c071c428b49f85b3e3aed006e2694c3d (diff)
downloadqpid-python-32c07273359d3c0a469d8a32ec9a1862de85ed0b.tar.gz
QPID-3363: prevent bind/unbind on default exchange
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1155545 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/cluster/UpdateClient.cpp')
-rw-r--r--cpp/src/qpid/cluster/UpdateClient.cpp6
1 files changed, 5 insertions, 1 deletions
diff --git a/cpp/src/qpid/cluster/UpdateClient.cpp b/cpp/src/qpid/cluster/UpdateClient.cpp
index f306517d37..fc104e8ca9 100644
--- a/cpp/src/qpid/cluster/UpdateClient.cpp
+++ b/cpp/src/qpid/cluster/UpdateClient.cpp
@@ -402,7 +402,11 @@ void UpdateClient::updateNonExclusiveQueue(const boost::shared_ptr<broker::Queue
}
void UpdateClient::updateBinding(client::AsyncSession& s, const std::string& queue, const QueueBinding& binding) {
- s.exchangeBind(queue, binding.exchange, binding.key, binding.args);
+ if (binding.exchange.size())
+ s.exchangeBind(queue, binding.exchange, binding.key, binding.args);
+ //else its the default exchange and there is no need to replicate
+ //the binding, the creation of the queue will have done so
+ //automatically
}
void UpdateClient::updateOutputTask(const sys::OutputTask* task) {