0003811: Router exception can expire gaps that contain data

JumpMind · Nov 30, 2018 · ece2e82 · ece2e82
1 parent 89ac93f
commit ece2e82
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
@@ -463,7 +463,7 @@ protected int routeDataForEachChannel() {
                 if (nodeChannel.isEnabled() && (readyChannels == null || readyChannels.contains(nodeChannel.getChannelId()))) {
                     processInfo.setCurrentChannelId(nodeChannel.getChannelId());
                     dataCount += routeDataForChannel(processInfo, nodeChannel, sourceNode);
-                } else {
+                } else if (!nodeChannel.isEnabled()) {
                     gapDetector.setIsAllDataRead(false);
                     if (log.isDebugEnabled() && !nodeChannel.isEnabled()) {
                         log.debug(
@@ -728,6 +728,8 @@ protected int routeDataForChannel(ProcessInfo processInfo, final NodeChannel nod
                             engine.getStatisticManager().setDataUnRouted(channelId, dataLeftToRoute);
                         }
                     }
+                } else {
+                    gapDetector.setIsAllDataRead(false);
                 }
             } catch (Exception e) {
                 if (context != null) {