summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/QueueCleaner.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2009-07-10 21:42:11 +0000
committerAndrew Stitcher <astitcher@apache.org>2009-07-10 21:42:11 +0000
commitf7248a708fad10a3e854b2131d3f2c686af9cc25 (patch)
tree216cc796605397bcb015d23958fc1907429454d8 /cpp/src/qpid/broker/QueueCleaner.cpp
parenta0ade0ee56188c1f0017cb565361ed2dea60d9ab (diff)
downloadqpid-python-f7248a708fad10a3e854b2131d3f2c686af9cc25.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@793121 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 0774dce2b7..814eca6751 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);
}