Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add some additional logs

This commit is contained in:
Timothy Bish 2014-01-29 12:41:43 -05:00
parent 8b993b4dc6
commit 19344991af
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
View File

@ -371,6 +371,9 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
LOG.trace("Dispatching End of Browse Command to consumer {}", md.getConsumerId()); LOG.trace("Dispatching End of Browse Command to consumer {}", md.getConsumerId());
} }
consumerContext.onMessageDispatch(md); 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) { } else if (command.getDataStructureType() == ConnectionError.DATA_STRUCTURE_TYPE) {
// Pass down any unexpected async errors. Should this close the connection? // Pass down any unexpected async errors. Should this close the connection?