svn commit: r795081 - /qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp

[tross]

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-subscr...@qpid.apache.org