activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject [07/29] git commit: Add some additional logs
Date Thu, 20 Mar 2014 17:44:18 GMT
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/b79947d4
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/b79947d4
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/b79947d4

Branch: refs/heads/activemq-5.9
Commit: b79947d46ec57a26317aaf462c35594b1b8f44f2
Parents: 80d6501
Author: Timothy Bish <tabish121@gmai.com>
Authored: Wed Jan 29 12:41:43 2014 -0500
Committer: Hadrian Zbarcea <hadrian@apache.org>
Committed: Thu Mar 20 13:07:42 2014 -0400

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


http://git-wip-us.apache.org/repos/asf/activemq/blob/b79947d4/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