From 68d1e980fcefc79ddcb4929ac549d9438785f342 Mon Sep 17 00:00:00 2001 From: jbertram Date: Thu, 25 Aug 2016 16:27:16 -0500 Subject: [PATCH] ARTEMIS-699 group ID reaper tx bug --- .../artemis/core/server/group/impl/LocalGroupingHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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) {