0003730: reverting, conflicts with pingback prevention

JumpMind · Oct 2, 2018 · 98a6142 · 98a6142
1 parent 7b4542e
commit 98a6142
Showing 1 changed file with 1 addition and 2 deletions.
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
@@ -634,8 +634,7 @@ protected boolean producesCommonBatches(Channel channel, String nodeGroupId, Lis
                                     String incomingTableName = triggerRouter2.getTrigger().getFullyQualifiedSourceTableName();
                                     String targetNodeGroupId = triggerRouter2.getRouter().getNodeGroupLink()
                                             .getTargetNodeGroupId();
-                                    if (incomingTableName.equals(outgoingTableName) && targetNodeGroupId.equals(nodeGroupId) 
-                                            && !"default".equals(triggerRouter2.getRouter().getRouterType())) {
+                                    if (incomingTableName.equals(outgoingTableName) && targetNodeGroupId.equals(nodeGroupId)) {
                                         producesCommonBatches = false;
                                         break;
                                     }