diff options
| author | Alan Conway <aconway@apache.org> | 2006-11-08 17:07:44 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2006-11-08 17:07:44 +0000 |
| commit | 5be658a8817b8092a7b53b116f622412a5d0aef6 (patch) | |
| tree | bbee363911f47bad6abe245629cacba0ebf3b9be /cpp/src/qpid/broker/HeadersExchange.cpp | |
| parent | 85fef3d1e669b240deae82cdd353620667a85e08 (diff) | |
| download | qpid-python-5be658a8817b8092a7b53b116f622412a5d0aef6.tar.gz | |
More reorg to separate APR/posix code, work in progress.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472545 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/HeadersExchange.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/HeadersExchange.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/HeadersExchange.cpp b/cpp/src/qpid/broker/HeadersExchange.cpp index 5d5cf2392c..0c4c290bbd 100644 --- a/cpp/src/qpid/broker/HeadersExchange.cpp +++ b/cpp/src/qpid/broker/HeadersExchange.cpp @@ -41,7 +41,7 @@ namespace { HeadersExchange::HeadersExchange(const string& _name) : Exchange(_name) { } void HeadersExchange::bind(Queue::shared_ptr queue, const string& routingKey, FieldTable* args){ - Locker locker(lock); + Mutex::ScopedLock locker(lock); std::string what = args->getString("x-match"); if (what != all && what != any) { THROW_QPID_ERROR(PROTOCOL_ERROR, "Invalid x-match value binding to headers exchange."); @@ -51,7 +51,7 @@ void HeadersExchange::bind(Queue::shared_ptr queue, const string& routingKey, Fi } void HeadersExchange::unbind(Queue::shared_ptr queue, const string& /*routingKey*/, FieldTable* args){ - Locker locker(lock); + Mutex::ScopedLock locker(lock); Bindings::iterator i = std::find(bindings.begin(),bindings.end(), Binding(*args, queue)); if (i != bindings.end()) bindings.erase(i); @@ -59,7 +59,7 @@ void HeadersExchange::unbind(Queue::shared_ptr queue, const string& /*routingKey void HeadersExchange::route(Deliverable& msg, const string& /*routingKey*/, FieldTable* args){ - Locker locker(lock);; + Mutex::ScopedLock locker(lock);; for (Bindings::iterator i = bindings.begin(); i != bindings.end(); ++i) { if (match(i->first, *args)) msg.deliverTo(i->second); } |
