0003831: Be more lenient in the calculation of whether a channel is

common
JumpMind · Dec 17, 2018 · 21245d2 · 21245d2
1 parent 38dd79f
commit 21245d2
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/RouterService.java
@@ -607,7 +607,9 @@ protected boolean producesCommonBatches(Channel channel, String nodeGroupId, Lis
                             String currentChannelId = triggerRouter2.getTrigger().getChannelId();
                             if (anotherChannelTableName.equals(currentTableName) && currentChannelId.equals(channelId)
                                     && triggerRouter.getRouter().getNodeGroupLink().getTargetNodeGroupId()
-                                            .equals(triggerRouter2.getRouter().getNodeGroupLink().getSourceNodeGroupId())) {
+                                            .equals(triggerRouter2.getRouter().getNodeGroupLink().getSourceNodeGroupId()) &&
+                                            triggerRouter.getRouter().getNodeGroupLink().getSourceNodeGroupId()
+                                            .equals(triggerRouter2.getRouter().getNodeGroupLink().getTargetNodeGroupId())) {
                                 testableTriggerRouters.add(triggerRouter);
                             }
                         }