summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Broker.cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2007-05-25 11:24:54 +0000
committerGordon Sim <gsim@apache.org>2007-05-25 11:24:54 +0000
commit45f0ee18e3dacf9e8c746009eaef4e17b0a44bf8 (patch)
tree67a2ae89ca92c9b4fdc94e2f6a817439e648d069 /cpp/src/qpid/broker/Broker.cpp
parentf646350b5e59ccf49f1253bd55f98d062769f2ee (diff)
downloadqpid-python-45f0ee18e3dacf9e8c746009eaef4e17b0a44bf8.tar.gz
Added support for recovering prepared transactions.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@541619 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Broker.cpp')
-rw-r--r--cpp/src/qpid/broker/Broker.cpp4
1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp
index de2f2c55f4..01e049bdda 100644
--- a/cpp/src/qpid/broker/Broker.cpp
+++ b/cpp/src/qpid/broker/Broker.cpp
@@ -92,8 +92,8 @@ Broker::Broker(const Broker::Options& conf) :
exchanges.declare(amq_match, HeadersExchange::typeName);
if(store.get()) {
- RecoveryManagerImpl recoverer(
- queues, exchanges, conf.stagingThreshold);
+ RecoveryManagerImpl recoverer(queues, exchanges, dtxManager,
+ conf.stagingThreshold);
store->recover(recoverer);
}