Skip to content

Commit 049bb42

Browse files
committed
[#2198] Fix pendingSends count to decrement on rolled-back send
1 parent d1517f6 commit 049bb42

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

  • activemq-broker/src/main/java/org/apache/activemq/broker/region

activemq-broker/src/main/java/org/apache/activemq/broker/region/Queue.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -888,6 +888,7 @@ public void afterRollback() throws Exception {
888888
if (store != null && messageContext.message.isPersistent()) {
889889
rollbackPendingCursorAdditions(messageContext.message.getMessageId());
890890
}
891+
pendingSends.decrementAndGet();
891892
messageContext.message.decrementReferenceCount();
892893
}
893894
}

0 commit comments

Comments
 (0)