You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by tr...@apache.org on 2009/07/17 15:39:26 UTC
svn commit: r795081 -
/qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp
Author: tross
Date: Fri Jul 17 13:39:26 2009
New Revision: 795081
URL: http://svn.apache.org/viewvc?rev=795081&view=rev
Log:
Improved debug logging
Modified:
qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp
Modified: qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp?rev=795081&r1=795080&r2=795081&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp Fri Jul 17 13:39:26 2009
@@ -46,6 +46,7 @@
{
if (mgmtObject != 0)
mgmtObject->resourceDestroy();
+ QPID_LOG(debug, "Remote Agent removed bank=[" << brokerBank << "." << agentBank << "]");
}
ManagementAgent::ManagementAgent () :
@@ -345,6 +346,8 @@
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 @@
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 @@
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 @@
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;
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org