diff options
| author | Ted Ross <tross@apache.org> | 2008-06-04 22:13:40 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2008-06-04 22:13:40 +0000 |
| commit | 5afbb19b7ceb60a694207b4c2da9f1378d9ec856 (patch) | |
| tree | 09a26695ebb5c9cc1b3adf95940cf87b2e554f4a /cpp/src/qpid/management/ManagementBroker.cpp | |
| parent | 3f913b51d3af8ec31c1c3ffbc8625a70dcc49e90 (diff) | |
| download | qpid-python-5afbb19b7ceb60a694207b4c2da9f1378d9ec856.tar.gz | |
Management cleanup - Synchronized with the spec on the Wiki
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@663386 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/management/ManagementBroker.cpp')
| -rw-r--r-- | cpp/src/qpid/management/ManagementBroker.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/cpp/src/qpid/management/ManagementBroker.cpp b/cpp/src/qpid/management/ManagementBroker.cpp index 2f30aa4c0b..24d18875b6 100644 --- a/cpp/src/qpid/management/ManagementBroker.cpp +++ b/cpp/src/qpid/management/ManagementBroker.cpp @@ -299,11 +299,11 @@ void ManagementBroker::PeriodicProcessing (void) { Buffer msgBuffer (msgChars, BUFSIZE); EncodeHeader (msgBuffer, 'c'); - object->writeConfig (msgBuffer); + object->writeProperties(msgBuffer); contentSize = BUFSIZE - msgBuffer.available (); msgBuffer.reset (); - routingKey = "mgmt." + uuid.str() + ".config." + object->getClassName (); + routingKey = "mgmt." + uuid.str() + ".prop." + object->getClassName (); SendBuffer (msgBuffer, contentSize, mExchange, routingKey); } @@ -311,11 +311,11 @@ void ManagementBroker::PeriodicProcessing (void) { Buffer msgBuffer (msgChars, BUFSIZE); EncodeHeader (msgBuffer, 'i'); - object->writeInstrumentation (msgBuffer); + object->writeStatistics(msgBuffer); contentSize = BUFSIZE - msgBuffer.available (); msgBuffer.reset (); - routingKey = "mgmt." + uuid.str () + ".inst." + object->getClassName (); + routingKey = "mgmt." + uuid.str () + ".stat." + object->getClassName (); SendBuffer (msgBuffer, contentSize, mExchange, routingKey); } @@ -681,8 +681,8 @@ void ManagementBroker::handleGetQueryLH (Buffer& inBuffer, string replyToKey, ui uint32_t outLen; EncodeHeader (outBuffer, 'g', sequence); - object->writeConfig (outBuffer); - object->writeInstrumentation (outBuffer, true); + object->writeProperties(outBuffer); + object->writeStatistics(outBuffer, true); outLen = MA_BUFFER_SIZE - outBuffer.available (); outBuffer.reset (); SendBuffer (outBuffer, outLen, dExchange, replyToKey); |
