diff options
Diffstat (limited to 'cpp/src/qpid/broker/Broker.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/Broker.cpp | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp index 65252f5415..7c96322f02 100644 --- a/cpp/src/qpid/broker/Broker.cpp +++ b/cpp/src/qpid/broker/Broker.cpp @@ -82,7 +82,7 @@ Broker::Broker(const Broker::Options& conf) : queues(store.get()), timeout(30000), stagingThreshold(0), - cleaner(&queues, timeout/10), + cleaner(&queues, 100), // clean every 100 auto delete declares. factory(*this), dtxManager(store.get()) { @@ -98,7 +98,6 @@ Broker::Broker(const Broker::Options& conf) : store->recover(recoverer); } - cleaner.start(); } @@ -128,7 +127,7 @@ void Broker::run() { void Broker::shutdown() { if (acceptor) acceptor->shutdown(); - cleaner.stop(); +//cct cleaner.cleanNow(); // do we need to delete on close? } Broker::~Broker() { |
