diff options
| author | Alan Conway <aconway@apache.org> | 2010-12-13 17:49:50 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-12-13 17:49:50 +0000 |
| commit | 40b9ecb1f1ba67a9cb08db6e25e20b7277879636 (patch) | |
| tree | 1100db1a50cf6bb590ca010295e810a8d0b1d3de /qpid/cpp | |
| parent | 8b85849170244ed9e7a34addd1628c183892cb65 (diff) | |
| download | qpid-python-40b9ecb1f1ba67a9cb08db6e25e20b7277879636.tar.gz | |
ManagementAgent.cpp: consistent logging of message lengths.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1045258 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/management/ManagementAgent.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/qpid/cpp/src/qpid/management/ManagementAgent.cpp b/qpid/cpp/src/qpid/management/ManagementAgent.cpp index 900f80fce6..fbbdf111c7 100644 --- a/qpid/cpp/src/qpid/management/ManagementAgent.cpp +++ b/qpid/cpp/src/qpid/management/ManagementAgent.cpp @@ -824,7 +824,7 @@ void ManagementAgent::periodicProcessing (void) 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 (void) 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 (void) 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(const string& body, const string& replyTo 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; } |