Author: aconway
Date: Mon Dec 13 17:49:50 2010
New Revision: 1045258
URL: http://svn.apache.org/viewvc?rev=1045258&view=rev
Log:
ManagementAgent.cpp: consistent logging of message lengths.
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=1045258&r1=1045257&r2=1045258&view=diff
==============================================================================
--- qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp (original)
+++ qpid/trunk/qpid/cpp/src/qpid/management/ManagementAgent.cpp Mon Dec 13
17:49:50 2010
@@ -824,7 +824,7 @@ void ManagementAgent::periodicProcessing
key << "console.obj.1.0." << packageName << "." <<
className;
msgBuffer.reset();
sendBufferLH(msgBuffer, contentSize, mExchange,
key.str()); // UNLOCKS USERLOCK
- QPID_LOG(trace, "SEND V1 Multicast ContentInd to=" <<
key.str() << " props=" << pcount << " stats=" << scount);
+ QPID_LOG(trace, "SEND V1 Multicast ContentInd to=" <<
key.str() << " props=" << pcount << " stats=" << scount << " len=" <<
contentSize);
}
}
@@ -893,7 +893,7 @@ void ManagementAgent::periodicProcessing
key << "console.obj.1.0." << packageName << "." <<
className;
msgBuffer.reset();
sendBufferLH(msgBuffer, contentSize, mExchange,
key.str()); // UNLOCKS USERLOCK
- QPID_LOG(trace, "SEND V1 Multicast ContentInd V1 (delete)
to=" << key.str());
+ QPID_LOG(trace, "SEND V1 Multicast ContentInd V1 (delete)
to=" << key.str() << " len=" << contentSize);
}
if (!(*lIter)->encodedV2.empty()) {
@@ -934,7 +934,7 @@ void ManagementAgent::periodicProcessing
key << "console.obj.1.0." << packageName << "." << className;
msgBuffer.reset();
sendBufferLH(msgBuffer, contentSize, mExchange, key.str());
// UNLOCKS USERLOCK
- QPID_LOG(trace, "SEND V1 Multicast ContentInd V1 (delete) to="
<< key.str());
+ QPID_LOG(trace, "SEND V1 Multicast ContentInd V1 (delete) to="
<< key.str() << " len=" << contentSize);
}
if (!list_.empty()) {
@@ -1987,12 +1987,12 @@ void ManagementAgent::handleGetQueryLH(c
ListCodec::encode(_list.front().asList(), content);
sendBufferLH(content, cid, headers, "amqp/list", v2Direct,
replyTo);
_list.pop_front();
- QPID_LOG(trace, "SENT QueryResponse (partial, query by schema_id)
to=" << replyTo << " size=" << content.length());
+ QPID_LOG(trace, "SENT QueryResponse (partial, query by schema_id)
to=" << replyTo << " len=" << content.length());
}
headers.erase("partial");
ListCodec::encode(_list.size() ? _list.front().asList() :
Variant::List(), content);
sendBufferLH(content, cid, headers, "amqp/list", v2Direct, replyTo);
- QPID_LOG(trace, "SENT QueryResponse (query by schema_id) to=" <<
replyTo << " size=" << content.length());
+ QPID_LOG(trace, "SENT QueryResponse (query by schema_id) to=" <<
replyTo << " len=" << content.length());
return;
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
