From 335399e4574a0676148ed82daea80f008a5484e7 Mon Sep 17 00:00:00 2001 From: Martin Ritchie Date: Thu, 17 Jul 2008 07:39:34 +0000 Subject: QPID-1177 : Fixed the format of the messages, realised that the transport.Connection uses a logging wrapper but in my haste to make the format the same in AMQProtocolHandler hadn't checked the output was as expected. Was missing the String.format. Also there was an extra debug level output of the sent frame. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677525 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) (limited to 'java') 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 28544324b1..8328d87b87 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: [%s] %s", this, message); + _protocolLogger.info(String.format("RECV: [%s] %s", this, message)); } if(message instanceof AMQFrame) @@ -574,7 +574,7 @@ public class AMQProtocolHandler extends IoHandlerAdapter { if (PROTOCOL_DEBUG) { - _protocolLogger.debug("SEND: [%s] %s", this, message); + _protocolLogger.debug(String.format("SEND: [%s] %s", this, message)); } final long sentMessages = _messagesOut++; @@ -587,10 +587,6 @@ public class AMQProtocolHandler extends IoHandlerAdapter } _connection.bytesSent(session.getWrittenBytes()); - if (debug) - { - _logger.debug("Sent frame " + message); - } } public StateWaiter createWaiter(Set states) throws AMQException -- cgit v1.2.1