diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-07-17 07:39:34 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-07-17 07:39:34 +0000 |
| commit | a92d7368ee693ca0c9b7518c2a735ab4318523e4 (patch) | |
| tree | a9f47d973c6d1f7fd5a91ac67d60141de72af2f1 /qpid/java/client/src | |
| parent | b4f78e457644c495008f0730d7e5cd7bf233b587 (diff) | |
| download | qpid-python-a92d7368ee693ca0c9b7518c2a735ab4318523e4.tar.gz | |
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
Diffstat (limited to 'qpid/java/client/src')
| -rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java | 8 |
1 files changed, 2 insertions, 6 deletions
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<AMQState> states) throws AMQException |