diff options
Diffstat (limited to 'cpp/src/qpid/broker/QueueFactory.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/QueueFactory.cpp | 2 |
1 files changed, 1 insertions, 1 deletions
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<Queue> QueueFactory::create(const std::string& name, const Que if (settings.groupKey.size()) { boost::shared_ptr<MessageGroupManager> mgm(MessageGroupManager::create( name, *(queue->messages), settings)); queue->allocator = mgm; - queue->addObserver(mgm); + queue->getObservers().add(mgm); } else { queue->allocator = boost::shared_ptr<MessageDistributor>(new FifoDistributor( *(queue->messages) )); } |