You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2014/09/01 22:45:42 UTC
svn commit: r1621881 -
/qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java
Author: robbie
Date: Mon Sep 1 20:45:42 2014
New Revision: 1621881
URL: http://svn.apache.org/r1621881
Log:
QPIDJMS-25: separate raw byte logging from the logger used for the other messages
Modified:
qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java
Modified: qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java
URL: http://svn.apache.org/viewvc/qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java?rev=1621881&r1=1621880&r2=1621881&view=diff
==============================================================================
--- qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java (original)
+++ qpid/jms/trunk/src/main/java/org/apache/qpid/jms/engine/AmqpConnectionDriverNetty.java Mon Sep 1 20:45:42 2014
@@ -56,6 +56,7 @@ import org.apache.qpid.proton.engine.Tra
public class AmqpConnectionDriverNetty
{
private static Logger LOGGER = Logger.getLogger(AmqpConnectionDriverNetty.class.getName());
+ private static Logger LOGGER_BYTES = Logger.getLogger(AmqpConnectionDriverNetty.class.getName() + ".BYTES");
private Bootstrap _bootstrap;
private NettyHandler _nettyHandler;
@@ -423,13 +424,14 @@ public class AmqpConnectionDriverNetty
private void echoBytes(String msgPrefix, ByteBuf buf)
{
//TODO: delete this method
- if(LOGGER.isLoggable(Level.FINEST))
+ if(LOGGER_BYTES.isLoggable(Level.FINEST))
{
ByteBuffer nio = buf.nioBuffer();
byte[] bytes = new byte[nio.limit()];
nio.get(bytes);
- logMessage(msgPrefix + new Binary(bytes));
+ String name = Thread.currentThread().getName();
+ LOGGER_BYTES.finest("[" + name + "] " + msgPrefix + new Binary(bytes));
}
}
}
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org