summaryrefslogtreecommitdiff
path: root/cpp/src
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2009-07-01 13:47:54 +0000
committerGordon Sim <gsim@apache.org>2009-07-01 13:47:54 +0000
commit78bb6d6ffe9ed3e61a1e0e7c8dc4bf26a5e33802 (patch)
treeb51427e7cd1fce2f18d996d7a18e781b24da90d5 /cpp/src
parent6f734e4aa938dccdc1c79e782908a0d1164ee526 (diff)
downloadqpid-python-78bb6d6ffe9ed3e61a1e0e7c8dc4bf26a5e33802.tar.gz
QPID-1963: hold lock across TopicExchange::isBound() method
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@790164 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
-rw-r--r--cpp/src/qpid/broker/TopicExchange.cpp1
1 files changed, 1 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/TopicExchange.cpp b/cpp/src/qpid/broker/TopicExchange.cpp
index 85c7a6a28e..4a22d91839 100644
--- a/cpp/src/qpid/broker/TopicExchange.cpp
+++ b/cpp/src/qpid/broker/TopicExchange.cpp
@@ -322,6 +322,7 @@ void TopicExchange::route(Deliverable& msg, const string& routingKey, const Fiel
bool TopicExchange::isBound(Queue::shared_ptr queue, const string* const routingKey, const FieldTable* const)
{
+ RWlock::ScopedRlock l(lock);
if (routingKey && queue) {
string key(normalize(*routingKey));
return isBound(queue, key);