summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/management
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2010-12-15 14:40:01 +0000
committerAlan Conway <aconway@apache.org>2010-12-15 14:40:01 +0000
commitc50499e4c309e43367c2ff4ab478d85f88c3124c (patch)
tree4a16a98213901f151d0550b9350b38b5bf041c85 /cpp/src/qpid/management
parent086fd98a8869bf141a525b30e9c0f33d71b2a655 (diff)
downloadqpid-python-c50499e4c309e43367c2ff4ab478d85f88c3124c.tar.gz
Bug 662765 - Management broker ID should be the same for members of a cluster.
Replicate management UUID and name to members of a cluster. See https://bugzilla.redhat.com/show_bug.cgi?id=662765. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1049566 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/management')
-rw-r--r--cpp/src/qpid/management/ManagementAgent.cpp4
-rw-r--r--cpp/src/qpid/management/ManagementAgent.h7
2 files changed, 6 insertions, 5 deletions
diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp
index fbbdf111c7..4bacb95c7b 100644
--- a/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/cpp/src/qpid/management/ManagementAgent.cpp
@@ -507,7 +507,7 @@ void ManagementAgent::sendBufferLH(Buffer& buf,
string routingKey)
{
if (suppressed) {
- QPID_LOG(trace, "Suppressed management message to " << routingKey);
+ QPID_LOG(trace, "Suppressing management message to " << routingKey);
return;
}
if (exchange.get() == 0) return;
@@ -562,7 +562,7 @@ void ManagementAgent::sendBufferLH(const string& data,
Variant::Map::const_iterator i;
if (suppressed) {
- QPID_LOG(trace, "Suppressed management message to " << routingKey);
+ QPID_LOG(trace, "Suppressing management message to " << routingKey);
return;
}
if (exchange.get() == 0) return;
diff --git a/cpp/src/qpid/management/ManagementAgent.h b/cpp/src/qpid/management/ManagementAgent.h
index 9829094a0f..7f5f3a856e 100644
--- a/cpp/src/qpid/management/ManagementAgent.h
+++ b/cpp/src/qpid/management/ManagementAgent.h
@@ -113,8 +113,6 @@ public:
const bool topic,
int qmfVersion);
- const framing::Uuid& getUuid() const { return uuid; }
-
/** Disallow a method. Attempts to call it will receive an exception with message. */
void disallow(const std::string& className, const std::string& methodName, const std::string& message);
@@ -138,7 +136,10 @@ public:
void setNextObjectId(uint64_t o) { nextObjectId = o; }
uint16_t getBootSequence(void) { return bootSequence; }
- void setBootSequence(uint16_t b) { bootSequence = b; }
+ void setBootSequence(uint16_t b) { bootSequence = b; writeData(); }
+
+ const framing::Uuid& getUuid() const { return uuid; }
+ void setUuid(const framing::Uuid& id) { uuid = id; writeData(); }
// TODO: remove these when Variant API moved into common library.
static types::Variant::Map toMap(const framing::FieldTable& from);