summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/QueueCleaner.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2009-07-30 14:06:49 +0000
committerAndrew Stitcher <astitcher@apache.org>2009-07-30 14:06:49 +0000
commit9c095c4cd694287151cc1fabcc274fd435944dee (patch)
treeaea55b408f4461f86cc2087629e71c21247ab392 /cpp/src/qpid/broker/QueueCleaner.cpp
parent20dfc1f76b845a7d6826f9a27923827fd60ea0e9 (diff)
downloadqpid-python-9c095c4cd694287151cc1fabcc274fd435944dee.tar.gz
Change all broker users of broker::Timer to use sys::Timer
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@799273 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/QueueCleaner.cpp')
-rw-r--r--cpp/src/qpid/broker/QueueCleaner.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/QueueCleaner.cpp b/cpp/src/qpid/broker/QueueCleaner.cpp
index 7a75ed013b..83f3f83520 100644
--- a/cpp/src/qpid/broker/QueueCleaner.cpp
+++ b/cpp/src/qpid/broker/QueueCleaner.cpp
@@ -26,15 +26,15 @@
namespace qpid {
namespace broker {
-QueueCleaner::QueueCleaner(QueueRegistry& q, Timer& t) : queues(q), timer(t) {}
+QueueCleaner::QueueCleaner(QueueRegistry& q, sys::Timer& t) : queues(q), timer(t) {}
void QueueCleaner::start(qpid::sys::Duration p)
{
- task = boost::intrusive_ptr<TimerTask>(new Task(*this, p));
+ task = new Task(*this, p);
timer.add(task);
}
-QueueCleaner::Task::Task(QueueCleaner& p, qpid::sys::Duration d) : TimerTask(d), parent(p) {}
+QueueCleaner::Task::Task(QueueCleaner& p, qpid::sys::Duration d) : sys::TimerTask(d), parent(p) {}
void QueueCleaner::Task::fire()
{
@@ -44,7 +44,7 @@ void QueueCleaner::Task::fire()
void QueueCleaner::fired()
{
queues.eachQueue(boost::bind(&Queue::purgeExpired, _1));
- task->reset();
+ task->setupNextFire();
timer.add(task);
}