MODULE: Do not allow changing group-transaction-events

apache · Nov 5, 2021 · bcf6e55 · bcf6e55
1 parent 9251e71
commit bcf6e55
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 20 deletions.
diff --git a/...ain/java/org/apache/geode/management/internal/cli/commands/AlterGatewaySenderCommand.java b/...ain/java/org/apache/geode/management/internal/cli/commands/AlterGatewaySenderCommand.java
@@ -113,18 +113,9 @@ public ResultModel alterGatewaySender(@CliOption(key = CliStrings.ALTER_GATEWAYS
           "alter-gateway-sender cannot be performed for --batch-time-interval values smaller then -1.");
     }
 
-    if (groupTransactionEvents != null && groupTransactionEvents
-        && !oldConfiguration.mustGroupTransactionEvents()) {
-      if (!oldConfiguration.isParallel() && (oldConfiguration.getDispatcherThreads() == null
-          || Integer.parseInt(oldConfiguration.getDispatcherThreads()) > 1)) {
-        return ResultModel.createError(
-            "alter-gateway-sender cannot be performed for --group-transaction-events attribute if serial sender and dispatcher-threads is greater than 1.");
-      }
-
-      if (oldConfiguration.isEnableBatchConflation()) {
-        return ResultModel.createError(
-            "alter-gateway-sender cannot be performed for --group-transaction-events attribute if batch-conflation is enabled.");
-      }
+    if (groupTransactionEvents != null && groupTransactionEvents) {
+      return ResultModel.createError(
+          "alter-gateway-sender cannot be performed for --group-transaction-events attribute.");
     }
 
     Set<DistributedMember> dsMembers = findMembers(onGroup, onMember);

diff --git a/...va/org/apache/geode/internal/cache/wan/wancommand/AlterGatewaySenderCommandDUnitTest.java b/...va/org/apache/geode/internal/cache/wan/wancommand/AlterGatewaySenderCommandDUnitTest.java
@@ -460,14 +460,8 @@ public void testCreateParallelGatewaySenderAndChangeGroupTransaction() throws Ex
         .containsOutput("sender1P");
 
     gfsh.executeAndAssertThat("alter gateway-sender --id=sender1P --group-transaction-events=true")
-        .statusIsSuccess();
-
-    // verify that server1's event queue has the default value
-    server1.invoke(() -> {
-      InternalCache cache = ClusterStartupRule.getCache();
-      GatewaySender sender = cache.getGatewaySender("sender1P");
-      assertThat(sender.mustGroupTransactionEvents()).isTrue();
-    });
+        .statusIsError()
+        .containsOutput("alter-gateway-sender cannot be performed for --group-transaction-events");
   }
 
   public static class MyGatewayEventFilter implements GatewayEventFilter {