Don't log the pull timed out messages that might still be in the
unconsumed list during rollback of unconsumed messages
This commit is contained in:
Timothy Bish 2016-04-13 16:53:00 -04:00
parent 82330793e9
commit aaecdff8b4
1 changed files with 3 additions and 1 deletions

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());
}
}