summaryrefslogtreecommitdiff
path: root/java/client
diff options
context:
space:
mode:
Diffstat (limited to 'java/client')
-rw-r--r--java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
index c07e4d6c2e..28544324b1 100644
--- a/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
+++ b/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
@@ -488,7 +488,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
{
if (PROTOCOL_DEBUG)
{
- _protocolLogger.info("Recv:"+message);
+ _protocolLogger.info("RECV: [%s] %s", this, message);
}
if(message instanceof AMQFrame)
@@ -574,7 +574,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter
{
if (PROTOCOL_DEBUG)
{
- _protocolLogger.info("Send:"+message);
+ _protocolLogger.debug("SEND: [%s] %s", this, message);
}
final long sentMessages = _messagesOut++;