summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Broker.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-08-11 10:06:24 +0000
committerGordon Sim <gsim@apache.org>2010-08-11 10:06:24 +0000
commita1eaf3a3abf8fc22a235b4ca1ce902be2834b3d9 (patch)
treeeb5b4acb42198c6cd9316b8aa0143262b00ca25e /cpp/src/qpid/broker/Broker.cpp
parent074d0aea9ca86b366445afd89c2b5afc75e0c369 (diff)
downloadqpid-python-a1eaf3a3abf8fc22a235b4ca1ce902be2834b3d9.tar.gz
Revert commits r981517 and r981435 that moved periodic purging of queues onto cluster's timer. If the timer fires during an update it causes errors; it also puts a potentially time consuming task on the clusters dispatch thread. Instead don't purge LVQs to avoid cluster inconsistencies (and more directly the assertion that aims to prevent these).
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@984357 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Broker.cpp')
-rw-r--r--cpp/src/qpid/broker/Broker.cpp3
1 files changed, 1 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp
index 5e0ca90e69..1a8bed1be0 100644
--- a/cpp/src/qpid/broker/Broker.cpp
+++ b/cpp/src/qpid/broker/Broker.cpp
@@ -156,7 +156,7 @@ Broker::Broker(const Broker::Options& conf) :
conf.replayFlushLimit*1024, // convert kb to bytes.
conf.replayHardLimit*1024),
*this),
- queueCleaner(queues, &timer),
+ queueCleaner(queues, timer),
queueEvents(poller,!conf.asyncQueueEvents),
recovery(true),
clusterUpdatee(false),
@@ -504,7 +504,6 @@ bool Broker::deferDeliveryImpl(const std::string& ,
void Broker::setClusterTimer(std::auto_ptr<sys::Timer> t) {
clusterTimer = t;
- queueCleaner.setTimer(clusterTimer.get());
}
const std::string Broker::TCP_TRANSPORT("tcp");