diff options
Diffstat (limited to 'cpp/src/qpid/broker/SessionHandlerFactoryImpl.cpp')
| -rw-r--r-- | cpp/src/qpid/broker/SessionHandlerFactoryImpl.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/SessionHandlerFactoryImpl.cpp b/cpp/src/qpid/broker/SessionHandlerFactoryImpl.cpp index 5b7bb1ff5e..57fff37653 100644 --- a/cpp/src/qpid/broker/SessionHandlerFactoryImpl.cpp +++ b/cpp/src/qpid/broker/SessionHandlerFactoryImpl.cpp @@ -48,12 +48,10 @@ SessionHandlerFactoryImpl::SessionHandlerFactoryImpl(const std::string& _store, exchanges.declare(amq_topic, TopicExchange::typeName); exchanges.declare(amq_fanout, FanOutExchange::typeName); exchanges.declare(amq_match, HeadersExchange::typeName); - cleaner.start(); -} -void SessionHandlerFactoryImpl::recover() -{ if(store.get()) store->recover(queues); + + cleaner.start(); } SessionHandler* SessionHandlerFactoryImpl::create(SessionContext* ctxt) |