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

https://issues.apache.org/jira/browse/AMQ-6245 

Don't log the pull timed out messages that might still be in the
unconsumed list during rollback of unconsumed messages
(cherry picked from commit aaecdff8b4)
This commit is contained in:
Timothy Bish 2016-04-13 16:53:00 -04:00
parent 7894d8a9a1
commit 857254b75b
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java
View File

@ -863,7 +863,9 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC
if (!this.info.isBrowser()) {
for (MessageDispatch old : list) {
// ensure we don't filter this as a duplicate
LOG.debug("on close, rollback duplicate: {}", old.getMessage().getMessageId());
if (old.getMessage() != null) {
LOG.debug("on close, rollback duplicate: {}", old.getMessage().getMessageId());
}
session.connection.rollbackDuplicate(this, old.getMessage());
}
}