diff options
Diffstat (limited to 'cpp/src/qpid/broker/QueueRegistry.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/QueueRegistry.cpp | 39 |
1 files changed, 2 insertions, 37 deletions
diff --git a/cpp/src/qpid/broker/QueueRegistry.cpp b/cpp/src/qpid/broker/QueueRegistry.cpp index bc7f00c7ef..f246c653ea 100644 --- a/cpp/src/qpid/broker/QueueRegistry.cpp +++ b/cpp/src/qpid/broker/QueueRegistry.cpp @@ -19,8 +19,6 @@ * */ #include "QueueRegistry.h" -#include "management/ManagementAgent.h" -#include "management/ManagementObjectQueue.h" #include "qpid/log/Statement.h" #include <sstream> #include <assert.h> @@ -29,7 +27,7 @@ using namespace qpid::broker; using namespace qpid::sys; QueueRegistry::QueueRegistry(MessageStore* const _store) : - counter(1), store(_store) {} + counter(1), store(_store), parent(0) {} QueueRegistry::~QueueRegistry(){} @@ -43,17 +41,9 @@ QueueRegistry::declare(const string& declareName, bool durable, QueueMap::iterator i = queues.find(name); if (i == queues.end()) { - Queue::shared_ptr queue(new Queue(name, autoDelete, durable ? store : 0, owner)); + Queue::shared_ptr queue(new Queue(name, autoDelete, durable ? store : 0, owner, parent)); queues[name] = queue; - if (managementAgent){ - ManagementObjectQueue::shared_ptr mgmtObject - (new ManagementObjectQueue (managementVhost->getObjectId (), name, durable, autoDelete)); - - queue->setMgmt (mgmtObject); - managementAgent->addObject(dynamic_pointer_cast<ManagementObject>(mgmtObject)); - } - return std::pair<Queue::shared_ptr, bool>(queue, true); } else { return std::pair<Queue::shared_ptr, bool>(i->second, false); @@ -61,16 +51,6 @@ QueueRegistry::declare(const string& declareName, bool durable, } void QueueRegistry::destroyLH (const string& name){ - if (managementAgent){ - ManagementObjectQueue::shared_ptr mgmtObject; - QueueMap::iterator i = queues.find(name); - - if (i != queues.end()){ - mgmtObject = i->second->getMgmt (); - mgmtObject->resourceDestroy (); - } - } - queues.erase(name); } @@ -105,18 +85,3 @@ string QueueRegistry::generateName(){ MessageStore* const QueueRegistry::getStore() const { return store; } - -void QueueRegistry::setManagementAgent (ManagementAgent::shared_ptr agent) -{ - managementAgent = agent; -} - -ManagementAgent::shared_ptr QueueRegistry::getManagementAgent (void) -{ - return managementAgent; -} - -void QueueRegistry::setManagementVhost (ManagementObject::shared_ptr vhost) -{ - managementVhost = vhost; -} |
