summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Exchange.cpp
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2009-01-27 02:08:25 +0000
committerAlan Conway <aconway@apache.org>2009-01-27 02:08:25 +0000
commit306114207d6ff6c3ec6d63f5ab6b4ff9e1dd7d4e (patch)
tree04c1f8f85b0cf469c7c7e526f436e09cd12e350a /cpp/src/qpid/broker/Exchange.cpp
parent57acf95c94d52b15b2ad6e6038bf3390d9063282 (diff)
downloadqpid-python-306114207d6ff6c3ec6d63f5ab6b4ff9e1dd7d4e.tar.gz
Cluster rename: dump -> update, newbie -> joiner
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@737971 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Exchange.cpp')
-rw-r--r--cpp/src/qpid/broker/Exchange.cpp10
1 files changed, 6 insertions, 4 deletions
diff --git a/cpp/src/qpid/broker/Exchange.cpp b/cpp/src/qpid/broker/Exchange.cpp
index 53c49bf0ce..f8b9e4b183 100644
--- a/cpp/src/qpid/broker/Exchange.cpp
+++ b/cpp/src/qpid/broker/Exchange.cpp
@@ -98,6 +98,8 @@ Exchange::Exchange (const string& _name, Manageable* parent) :
}
}
+static const std::string QPID_MANAGEMENT("qpid.management");
+
Exchange::Exchange(const string& _name, bool _durable, const qpid::framing::FieldTable& _args,
Manageable* parent)
: name(_name), durable(_durable), args(_args), alternateUsers(0), persistenceId(0),
@@ -111,9 +113,9 @@ Exchange::Exchange(const string& _name, bool _durable, const qpid::framing::Fiel
mgmtExchange = new _qmf::Exchange (agent, this, parent, _name, durable);
mgmtExchange->set_arguments(args);
if (!durable) {
- if (name == "") {
+ if (name.empty()) {
agent->addObject (mgmtExchange, 0x1000000000000004LL); // Special default exchange ID
- } else if (name == "qpid.management") {
+ } else if (name == QPID_MANAGEMENT) {
agent->addObject (mgmtExchange, 0x1000000000000005LL); // Special management exchange ID
} else {
ManagementBroker* mb = dynamic_cast<ManagementBroker*>(agent);
@@ -125,12 +127,12 @@ Exchange::Exchange(const string& _name, bool _durable, const qpid::framing::Fiel
sequence = _args.get(qpidMsgSequence);
if (sequence) {
- QPID_LOG(debug, "Configured exchange "+ _name +" with Msg sequencing");
+ QPID_LOG(debug, "Configured exchange " << _name << " with Msg sequencing");
args.setInt64(std::string(qpidSequenceCounter), sequenceNo);
}
ive = _args.get(qpidIVE);
- if (ive) QPID_LOG(debug, "Configured exchange "+ _name +" with Initial Value");
+ if (ive) QPID_LOG(debug, "Configured exchange " << _name << " with Initial Value");
}
Exchange::~Exchange ()