You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ri...@apache.org on 2008/07/17 09:39:34 UTC
svn commit: r677525 -
/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Author: ritchiem
Date: Thu Jul 17 00:39:34 2008
New Revision: 677525
URL: http://svn.apache.org/viewvc?rev=677525&view=rev
Log:
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.
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
Modified: incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java?rev=677525&r1=677524&r2=677525&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java (original)
+++ incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/protocol/AMQProtocolHandler.java Thu Jul 17 00:39:34 2008
@@ -488,7 +488,7 @@
{
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 @@
{
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 @@
}
_connection.bytesSent(session.getWrittenBytes());
- if (debug)
- {
- _logger.debug("Sent frame " + message);
- }
}
public StateWaiter createWaiter(Set<AMQState> states) throws AMQException