0003590: If routing is backed up and a restart happens gaps with data

can be expired causing missing data
JumpMind · Jun 1, 2018 · ae443c0 · ae443c0
1 parent 8620af8
commit ae443c0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapFastDetector.java
@@ -124,6 +124,7 @@ public void beforeRouting() {
                 queryDataIdMap();
                 processInfo.setStatus(ProcessStatus.OK);
                 log.info("Querying data in gaps from database took {} ms", System.currentTimeMillis() - ts);
+                isAllDataRead = false;
                 afterRouting();
                 reset();
                 log.info("Full gap analysis is done after {} ms", System.currentTimeMillis() - ts);
@@ -543,6 +544,9 @@ public void addDataIds(List<Long> dataIds) {
         this.dataIds.addAll(dataIds);
     }
 
+    /**
+     * This method is called for each channel that is routed.  Once it is set for a routing pass it should remain set until the routing pass is done.
+     */
     public void setIsAllDataRead(boolean isAllDataRead) {
         this.isAllDataRead &= isAllDataRead;
     }