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 <[email protected]> Authored: Wed Jan 29 12:41:43 2014 -0500 Committer: Timothy Bish <[email protected]> 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?
