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

ARTEMIS-1730 fix expiry without address or bindings

This commit is contained in:
Ilkka Virolainen 2018-03-02 14:18:40 +02:00 committed by Timothy Bish
parent 913d7ecac2
commit 66e81c500a
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/QueueImpl.java
View File

@ -2741,6 +2741,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
if (bindingList.getBindings().isEmpty()) { if (bindingList.getBindings().isEmpty()) {
ActiveMQServerLogger.LOGGER.errorExpiringReferencesNoBindings(expiryAddress); ActiveMQServerLogger.LOGGER.errorExpiringReferencesNoBindings(expiryAddress);
acknowledge(tx, ref, AckReason.EXPIRED);
} else { } else {
move(expiryAddress, tx, ref, true, true); move(expiryAddress, tx, ref, true, true);
} }
@ -2751,7 +2752,7 @@ public class QueueImpl extends CriticalComponentImpl implements Queue {
ActiveMQServerLogger.LOGGER.errorExpiringReferencesNoQueue(name); ActiveMQServerLogger.LOGGER.errorExpiringReferencesNoQueue(name);
} }
acknowledge(tx, ref); acknowledge(tx, ref, AckReason.EXPIRED);
} }
} }