From a92d7368ee693ca0c9b7518c2a735ab4318523e4 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@677525 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) (limited to 'qpid/java/client/src') diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java b/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java index 28544324b1..8328d87b87 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java +++ b/qpid/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