summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/BrokerQueue.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-06-14 07:12:14 +0000
committerGordon Sim <gsim@apache.org>2007-06-14 07:12:14 +0000
commitb3747b9e1a5090a5eea0ac067b94d259f17ee09a (patch)
tree9e20e176532ccddac807c7302422c3c03ece2e54 /cpp/src/qpid/broker/BrokerQueue.cpp
parent9f8a87e8fe1ac33935c816cf5fdc2c68aef3e556 (diff)
downloadqpid-python-b3747b9e1a5090a5eea0ac067b94d259f17ee09a.tar.gz
Add ability for a queue to record all bindings to it, such that these can be removed when the queue is deleted.
Fix to QPID-438 git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@547151 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/BrokerQueue.cpp')
-rw-r--r--cpp/src/qpid/broker/BrokerQueue.cpp10
1 files changed, 10 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/BrokerQueue.cpp b/cpp/src/qpid/broker/BrokerQueue.cpp
index 3521e63444..58a8c85fcb 100644
--- a/cpp/src/qpid/broker/BrokerQueue.cpp
+++ b/cpp/src/qpid/broker/BrokerQueue.cpp
@@ -238,6 +238,16 @@ void Queue::destroy()
}
}
+void Queue::bound(const string& exchange, const string& key, const FieldTable& args)
+{
+ bindings.add(exchange, key, args);
+}
+
+void Queue::unbind(ExchangeRegistry& exchanges, Queue::shared_ptr shared_ref)
+{
+ bindings.unbind(exchanges, shared_ref);
+}
+
void Queue::setPolicy(std::auto_ptr<QueuePolicy> _policy)
{
policy = _policy;