0005450: Routing default batch algorithm protection against large

transactions
JumpMind · Sep 8, 2022 · 217bdaf · 217bdaf
1 parent 4697850
commit 217bdaf
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java b/...ric-core/src/test/java/org/jumpmind/symmetric/service/impl/AbstractRouterServiceTest.java
@@ -131,9 +131,9 @@ public void testMultiChannelRoutingToEveryone() {
         getRouterService().routeData(true);
         batches = getOutgoingBatchService().getOutgoingBatches(NODE_GROUP_NODE_1.getNodeId(), false);
         filterForChannels(batches, testChannel, otherChannel);
-        Assert.assertEquals(getDbDialect().supportsTransactionId() ? 3 : 17, batches.getBatches().size());
+        Assert.assertEquals(getDbDialect().supportsTransactionId() ? 10 : 17, batches.getBatches().size());
         Assert.assertEquals(2, countBatchesForChannel(batches, testChannel));
-        Assert.assertEquals(getDbDialect().supportsTransactionId() ? 1 : 15, countBatchesForChannel(batches, otherChannel));
+        Assert.assertEquals(getDbDialect().supportsTransactionId() ? 8 : 15, countBatchesForChannel(batches, otherChannel));
     }
 
     public void testLookupTableRouting() {