summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/QueueRegistry.cpp
diff options
context:
space:
mode:
authorCarl C. Trieloff <cctrieloff@apache.org>2007-10-31 00:43:11 +0000
committerCarl C. Trieloff <cctrieloff@apache.org>2007-10-31 00:43:11 +0000
commit9d7759e7acb7f14f3e291f721f7235c7769a2499 (patch)
treec9e97ee5e825f087325c99f9bd46a68bb8506761 /cpp/src/qpid/broker/QueueRegistry.cpp
parent342320c6f99cfb4c83daf9aacf407a372cfb0bd6 (diff)
downloadqpid-python-9d7759e7acb7f14f3e291f721f7235c7769a2499.tar.gz
- QPID-667
- for Ted Ross - built and tested. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@590523 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/QueueRegistry.cpp')
-rw-r--r--cpp/src/qpid/broker/QueueRegistry.cpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/QueueRegistry.cpp b/cpp/src/qpid/broker/QueueRegistry.cpp
index 6c87e5ff98..bc572e4238 100644
--- a/cpp/src/qpid/broker/QueueRegistry.cpp
+++ b/cpp/src/qpid/broker/QueueRegistry.cpp
@@ -59,8 +59,7 @@ QueueRegistry::declare(const string& declareName, bool durable,
}
}
-void QueueRegistry::destroy(const string& name){
- RWlock::ScopedWlock locker(lock);
+void QueueRegistry::destroyLH (const string& name){
if (managementAgent){
ManagementObjectQueue::shared_ptr mgmtObject;
QueueMap::iterator i = queues.find(name);
@@ -74,6 +73,11 @@ void QueueRegistry::destroy(const string& name){
queues.erase(name);
}
+void QueueRegistry::destroy (const string& name){
+ RWlock::ScopedWlock locker(lock);
+ destroyLH (name);
+}
+
Queue::shared_ptr QueueRegistry::find(const string& name){
RWlock::ScopedRlock locker(lock);
QueueMap::iterator i = queues.find(name);