summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/QueueCleaner.cpp
diff options
context:
space:
mode:
authorKim van der Riet <kpvdr@apache.org>2009-07-13 15:00:58 +0000
committerKim van der Riet <kpvdr@apache.org>2009-07-13 15:00:58 +0000
commit15daf8342812786490f8a8dabcc5ba3cee8593e6 (patch)
tree69ce95f978a7c6b7cfded0f025ffce7b1dd5d220 /cpp/src/qpid/broker/QueueCleaner.cpp
parentb7ec99208bb38dc0cad3a7fd42b8e652610a192a (diff)
downloadqpid-python-15daf8342812786490f8a8dabcc5ba3cee8593e6.tar.gz
Reverted checkins 793119, 793120, 793121, 793122 because of problems with heartbeats and the store tests.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793602 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 814eca6751..0774dce2b7 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, sys::Timer& t) : queues(q), timer(t) {}
+QueueCleaner::QueueCleaner(QueueRegistry& q, Timer& t) : queues(q), timer(t) {}
void QueueCleaner::start(qpid::sys::Duration p)
{
- task = new Task(*this, p);
+ task = boost::intrusive_ptr<TimerTask>(new Task(*this, p));
timer.add(task);
}
-QueueCleaner::Task::Task(QueueCleaner& p, qpid::sys::Duration d) : sys::TimerTask(d), parent(p) {}
+QueueCleaner::Task::Task(QueueCleaner& p, qpid::sys::Duration d) : 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->setupNextFire();
+ task->reset();
timer.add(task);
}