diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java index 3d8bdd6a96..6d21be2405 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/impl/RefsOperation.java @@ -191,7 +191,11 @@ public class RefsOperation extends TransactionOperationAbstract { @Override public synchronized List getRelatedMessageReferences() { List listRet = new LinkedList<>(); - listRet.addAll(listRet); + + if (refsToAck != null && !refsToAck.isEmpty()) { + listRet.addAll(refsToAck); + } + return listRet; }