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