summaryrefslogtreecommitdiff
path: root/cpp
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2010-07-09 16:06:44 +0000
committerGordon Sim <gsim@apache.org>2010-07-09 16:06:44 +0000
commit17124ec47822ef799e5dd71348f4434359a46ab1 (patch)
tree2942c6e71979779297be1f2e3343d04cf0697905 /cpp
parent569e13753815e8d63c1eb9003922196d2624623b (diff)
downloadqpid-python-17124ec47822ef799e5dd71348f4434359a46ab1.tar.gz
QPID-2727: Handle exceptions in Broker constructor and call finalise to safely cleanup plugins
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@962586 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp')
-rw-r--r--cpp/src/qpid/broker/Broker.cpp5
1 files changed, 5 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Broker.cpp b/cpp/src/qpid/broker/Broker.cpp
index 4c2bd9c5bf..db3767bb59 100644
--- a/cpp/src/qpid/broker/Broker.cpp
+++ b/cpp/src/qpid/broker/Broker.cpp
@@ -165,6 +165,7 @@ Broker::Broker(const Broker::Options& conf) :
getKnownBrokers(boost::bind(&Broker::getKnownBrokersImpl, this)),
deferDelivery(boost::bind(&Broker::deferDeliveryImpl, this, _1, _2))
{
+ try {
if (conf.enableMgmt) {
QPID_LOG(info, "Management enabled");
managementAgent->configure(dataDir.isEnabled() ? dataDir.getPath() : string(),
@@ -289,6 +290,10 @@ Broker::Broker(const Broker::Options& conf) :
} else if (conf.knownHosts != knownHostsNone) {
knownBrokers.push_back(Url(conf.knownHosts));
}
+ } catch (const std::exception& e) {
+ finalize();
+ throw;
+ }
}
void Broker::declareStandardExchange(const std::string& name, const std::string& type)