From 50593c783fbcf9e85ae11152f159a7545beb0647 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Fri, 13 Dec 2013 19:30:01 +0000 Subject: QPID-5421: Refactor: clean up QueueObservers. Refactor of queue observers to use the broker::Observers base class. Simplifies Queue code and makes it more consistent with other observers (BrokerObservers, ConnectionObservers.) Modified Observers base class to allow identical locking behaviour to previous impementation. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1550818 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/QueueFactory.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'cpp/src/qpid/broker/QueueFactory.cpp') diff --git a/cpp/src/qpid/broker/QueueFactory.cpp b/cpp/src/qpid/broker/QueueFactory.cpp index e5d9431555..d31b120cae 100644 --- a/cpp/src/qpid/broker/QueueFactory.cpp +++ b/cpp/src/qpid/broker/QueueFactory.cpp @@ -90,7 +90,7 @@ boost::shared_ptr QueueFactory::create(const std::string& name, const Que if (settings.groupKey.size()) { boost::shared_ptr mgm(MessageGroupManager::create( name, *(queue->messages), settings)); queue->allocator = mgm; - queue->addObserver(mgm); + queue->getObservers().add(mgm); } else { queue->allocator = boost::shared_ptr(new FifoDistributor( *(queue->messages) )); } -- cgit v1.2.1