activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1488048 - /activemq/trunk/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
Date Thu, 30 May 2013 23:22:16 GMT
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;



Mime
View raw message