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
index dcfe2d5f5f..03508e3230 100644
--- 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
@@ -500,7 +500,7 @@ protected long routeDataForChannel(ProcessInfo processInfo, final NodeChannel no
             if (overrideBatchesByNodes != null) {
                 context.getBatchesByNodes().putAll(overrideBatchesByNodes);
             }
-            if (overrideBatchesByNodes != null) {
+            if (overrideBatchesByGroups != null) {
                 context.getBatchesByGroups().putAll(overrideBatchesByGroups);
             }