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 | 9d1f9feec91ebc4a2da9ac5ae536b35c8580131e (patch) | |
| tree | 27ca5922b5df7ea3862028d113e063e20a692f1b /cpp/src | |
| parent | 35a2549305c431125787752e0d29dbe27b530ec2 (diff) | |
| download | qpid-python-9d1f9feec91ebc4a2da9ac5ae536b35c8580131e.tar.gz | |
ManagementAgent.cpp: consistent logging of message lengths.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1045258 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/management/ManagementAgent.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/cpp/src/qpid/management/ManagementAgent.cpp b/cpp/src/qpid/management/ManagementAgent.cpp index 900f80fce6..fbbdf111c7 100644 --- a/cpp/src/qpid/management/ManagementAgent.cpp +++ b/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; } |