diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/LocalGroupingHandler.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/LocalGroupingHandler.java index 9b2058c600..60e9ae8d1c 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/LocalGroupingHandler.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/group/impl/LocalGroupingHandler.java @@ -444,9 +444,9 @@ public final class LocalGroupingHandler extends GroupHandlingAbstract { storageManager.deleteGrouping(txID, groupBinding); if (expiredGroups >= 1000 && txID >= 0) { + storageManager.commitBindings(txID); expiredGroups = 0; txID = -1; - storageManager.commitBindings(txID); } } catch (Exception e) {