summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/QueueRegistry.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/broker/QueueRegistry.cpp')
-rw-r--r--cpp/src/qpid/broker/QueueRegistry.cpp39
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;
-}