summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Broker.cpp
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2012-10-03 13:36:37 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2012-10-03 13:36:37 +0000
commit378aa46b6ac8288e23a32672d47072457ee830dd (patch)
tree7eb4c198e4fc6ad6ad285fd5db8b4e0083f7eb51 /cpp/src/qpid/broker/Broker.cpp
parente091121f8c4a153070fbb6bd5fc92136f3ebf55f (diff)
downloadqpid-python-378aa46b6ac8288e23a32672d47072457ee830dd.tar.gz
QPID-4347: do not store Links/Bridges if they are created via recovery.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1393479 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, 3 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp
index d45dbc61d2..5b59decd69 100644
--- a/cpp/src/qpid/broker/Broker.cpp
+++ b/cpp/src/qpid/broker/Broker.cpp
@@ -214,6 +214,7 @@ Broker::Broker(const Broker::Options& conf) :
*this),
mgmtObject(0),
queueCleaner(queues, &timer),
+ recoveryInProgress(false),
recovery(true),
inCluster(false),
clusterUpdatee(false),
@@ -292,7 +293,9 @@ Broker::Broker(const Broker::Options& conf) :
// broker to join a cluster.
if (getRecovery()) {
RecoveryManagerImpl recoverer(queues, exchanges, links, dtxManager);
+ recoveryInProgress = true;
store->recover(recoverer);
+ recoveryInProgress = false;
}
else {
QPID_LOG(notice, "Cluster recovery: recovered journal data discarded and journal files pushed down");