summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/management
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2009-07-17 13:39:26 +0000
committerTed Ross <tross@apache.org>2009-07-17 13:39:26 +0000
commit10c869b18fbfcd9952675431cd54b1e32073aa0d (patch)
treee63d9c870e293e58056f1e4c2d52af4d85aaaa9f /cpp/src/qpid/management
parent9a95fdef8beee204e2a76b1895f748c1c29289de (diff)
downloadqpid-python-10c869b18fbfcd9952675431cd54b1e32073aa0d.tar.gz
Improved debug logging
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@795081 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/management')
-rw-r--r--cpp/src/qpid/management/ManagementAgent.cpp9
1 files changed, 8 insertions, 1 deletions
diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp
index bc106dbe48..3ea38ca45e 100644
--- a/cpp/src/qpid/management/ManagementAgent.cpp
+++ b/cpp/src/qpid/management/ManagementAgent.cpp
@@ -46,6 +46,7 @@ ManagementAgent::RemoteAgent::~RemoteAgent ()
{
if (mgmtObject != 0)
mgmtObject->resourceDestroy();
+ QPID_LOG(debug, "Remote Agent removed bank=[" << brokerBank << "." << agentBank << "]");
}
ManagementAgent::ManagementAgent () :
@@ -345,6 +346,8 @@ void ManagementAgent::periodicProcessing (void)
baseIter != managementObjects.end();
baseIter++) {
ManagementObject* baseObject = baseIter->second;
+ uint32_t pcount = 0;
+ uint32_t scount = 0;
//
// Skip until we find a base object requiring a sent message.
@@ -369,11 +372,13 @@ void ManagementAgent::periodicProcessing (void)
if (object->getConfigChanged() || object->getForcePublish() || object->isDeleted()) {
encodeHeader(msgBuffer, 'c');
object->writeProperties(msgBuffer);
+ pcount++;
}
if (object->hasInst() && (object->getInstChanged() || object->getForcePublish())) {
encodeHeader(msgBuffer, 'i');
object->writeStatistics(msgBuffer);
+ scount++;
}
if (object->isDeleted())
@@ -391,7 +396,7 @@ void ManagementAgent::periodicProcessing (void)
stringstream key;
key << "console.obj.1.0." << baseObject->getPackageName() << "." << baseObject->getClassName();
sendBuffer(msgBuffer, contentSize, mExchange, key.str());
- QPID_LOG(debug, "SEND Multicast ContentInd to=" << key.str());
+ QPID_LOG(debug, "SEND Multicast ContentInd to=" << key.str() << " props=" << pcount << " stats=" << scount);
}
}
@@ -865,6 +870,8 @@ void ManagementAgent::handleAttachRequestLH (Buffer& inBuffer, string replyToKey
remoteAgents[connectionRef] = agent;
+ QPID_LOG(debug, "Remote Agent registered bank=[" << brokerBank << "." << assignedBank << "] replyTo=" << replyToKey);
+
// Send an Attach Response
Buffer outBuffer (outputBuffer, MA_BUFFER_SIZE);
uint32_t outLen;