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
