svn commit: r1488048 - /activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java

[tabish]

Author: tabish
Date: Thu May 30 23:22:16 2013
New Revision: 1488048

URL: http://svn.apache.org/r1488048
Log:
Add some more tracing capabilities 

Modified:
    
activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java

Modified: 
activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java?rev=1488048&r1=1488047&r2=1488048&view=diff
==============================================================================
--- 
activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
 (original)
+++ 
activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
 Thu May 30 23:22:16 2013
@@ -516,6 +516,10 @@ class AmqpProtocolConverter {
                 message.setMessageId(new MessageId(producerId, 
messageIdGenerator.getNextSequenceId()));
             }
 
+            if (LOG.isTraceEnabled()) {
+                LOG.trace("Inbound Message:{} from Producer:{}", 
message.getMessageId(), producerId);
+            }
+
             DeliveryState remoteState = delivery.getRemoteState();
             if (remoteState != null && remoteState instanceof 
TransactionalState) {
                 TransactionalState s = (TransactionalState) remoteState;