summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/management/ManagementAgent.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/management/ManagementAgent.cpp')
-rw-r--r--qpid/cpp/src/qpid/management/ManagementAgent.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/cpp/src/qpid/management/ManagementAgent.cpp b/qpid/cpp/src/qpid/management/ManagementAgent.cpp
index 3ea38ca45e..2df10b1e95 100644
--- a/qpid/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/qpid/cpp/src/qpid/management/ManagementAgent.cpp
@@ -62,7 +62,6 @@ ManagementAgent::ManagementAgent () :
ManagementAgent::~ManagementAgent ()
{
- timer.stop();
{
Mutex::ScopedLock lock (userLock);
@@ -90,9 +89,10 @@ void ManagementAgent::configure(const string& _dataDir, uint16_t _interval,
dataDir = _dataDir;
interval = _interval;
broker = _broker;
+ timer = &_broker->getTimer();
threadPoolSize = _threads;
ManagementObject::maxThreads = threadPoolSize;
- timer.add (intrusive_ptr<TimerTask> (new Periodic(*this, interval)));
+ timer->add (new Periodic(*this, interval));
// Get from file or generate and save to file.
if (dataDir.empty())
@@ -219,7 +219,7 @@ ManagementAgent::Periodic::~Periodic () {}
void ManagementAgent::Periodic::fire ()
{
- agent.timer.add (intrusive_ptr<TimerTask> (new Periodic (agent, agent.interval)));
+ agent.timer->add (new Periodic (agent, agent.interval));
agent.periodicProcessing ();
}