From 5644e4fbfd777921b33874aed13c45d544c8a383 Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Fri, 17 Oct 2008 01:27:45 +0000 Subject: Feature requested by AndrewM for M4... - provide initial value support, for late joining consumers git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@705443 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/DirectExchange.cpp | 21 ++++++++++++--------- 1 file changed, 12 insertions(+), 9 deletions(-) (limited to 'cpp/src/qpid/broker/DirectExchange.cpp') diff --git a/cpp/src/qpid/broker/DirectExchange.cpp b/cpp/src/qpid/broker/DirectExchange.cpp index f760bc9747..8fc8260f9e 100644 --- a/cpp/src/qpid/broker/DirectExchange.cpp +++ b/cpp/src/qpid/broker/DirectExchange.cpp @@ -43,17 +43,20 @@ DirectExchange::DirectExchange(const std::string& _name, bool _durable, } bool DirectExchange::bind(Queue::shared_ptr queue, const string& routingKey, const FieldTable*){ - Mutex::ScopedLock l(lock); - Binding::shared_ptr b(new Binding (routingKey, queue, this)); - if (bindings[routingKey].add_unless(b, MatchQueue(queue))) { - if (mgmtExchange != 0) { - mgmtExchange->inc_bindingCount(); - ((_qmf::Queue*) queue->GetManagementObject())->inc_bindingCount(); + { + Mutex::ScopedLock l(lock); + Binding::shared_ptr b(new Binding (routingKey, queue, this)); + if (bindings[routingKey].add_unless(b, MatchQueue(queue))) { + if (mgmtExchange != 0) { + mgmtExchange->inc_bindingCount(); + ((_qmf::Queue*) queue->GetManagementObject())->inc_bindingCount(); + } + } else { + return false; } - return true; - } else { - return false; } + routeIVE(); + return true; } bool DirectExchange::unbind(Queue::shared_ptr queue, const string& routingKey, const FieldTable* /*args*/){ -- cgit v1.2.1