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 cc31a04650c..3d8bdd6a96f 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 @@ -132,16 +132,16 @@ public void afterRollback(final Transaction tx) { message.incrementRefCount(); } ackedTX.commit(true); - - if (pagedMessagesToPostACK != null) { - for (MessageReference refmsg : pagedMessagesToPostACK) { - ((PagedReference)refmsg).removePendingFlag(); - } - } } catch (Exception e) { ActiveMQServerLogger.LOGGER.failedToProcessMessageReferenceAfterRollback(e); } } + + if (pagedMessagesToPostACK != null) { + for (MessageReference refmsg : pagedMessagesToPostACK) { + ((PagedReference)refmsg).removePendingFlag(); + } + } } protected void rollbackRedelivery(Transaction tx, MessageReference ref, long timeBase, Map> queueMap) throws Exception {