activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject [1/2] git commit: Add some additional logs
Date Wed, 29 Jan 2014 19:58:45 GMT
Updated Branches:
  refs/heads/trunk 8b993b4dc -> 2f9c43f11


Add some additional logs

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/19344991
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/19344991
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/19344991

Branch: refs/heads/trunk
Commit: 19344991af148ea46ef0492c1f9561a93f610448
Parents: 8b993b4
Author: Timothy Bish <tabish121@gmai.com>
Authored: Wed Jan 29 12:41:43 2014 -0500
Committer: Timothy Bish <tabish121@gmai.com>
Committed: Wed Jan 29 12:41:43 2014 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/transport/amqp/AmqpProtocolConverter.java | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/19344991/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
index 78ee912..1e43cba 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
@@ -371,6 +371,9 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
                     LOG.trace("Dispatching End of Browse Command to consumer {}", md.getConsumerId());
                 }
                 consumerContext.onMessageDispatch(md);
+                if (md.getMessage() != null) {
+                    LOG.trace("Finished Dispatch of MessageId: {} to consumer", md.getMessage().getMessageId());
+                }
             }
         } else if (command.getDataStructureType() == ConnectionError.DATA_STRUCTURE_TYPE)
{
             // Pass down any unexpected async errors. Should this close the connection?


Mime
View raw message