From 33d8343d134a391fa7d0a338fafad1a22ff58dc3 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Fri, 30 Mar 2007 15:50:07 +0000 Subject: Refactored the MessageStore interface to restrict visibility of broker core from store implementations. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@524139 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/lib/broker/Broker.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'cpp/lib/broker/Broker.cpp') diff --git a/cpp/lib/broker/Broker.cpp b/cpp/lib/broker/Broker.cpp index 335ce2b3a0..fa80867b69 100644 --- a/cpp/lib/broker/Broker.cpp +++ b/cpp/lib/broker/Broker.cpp @@ -29,6 +29,7 @@ #include "MessageStoreModule.h" #include "NullMessageStore.h" #include "ProtocolInitiation.h" +#include "RecoveryManagerImpl.h" #include "Connection.h" #include "sys/ConnectionInputHandler.h" #include "sys/ConnectionInputHandlerFactory.h" @@ -61,9 +62,8 @@ Broker::Broker(const Configuration& conf) : exchanges.declare(amq_match, HeadersExchange::typeName); if(store.get()) { - RecoveryManager recoverer(queues, exchanges); - MessageStoreSettings storeSettings = { getStagingThreshold() }; - store->recover(recoverer, &storeSettings); + RecoveryManagerImpl recoverer(queues, exchanges, conf.getStagingThreshold()); + store->recover(recoverer); } cleaner.start(); -- cgit v1.2.1