0002478: Failed to route and batch on channel

JumpMind · Jan 29, 2016 · 8dfb218 · 8dfb218
1 parent 48a87cc
commit 8dfb218
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapRouteReader.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapRouteReader.java
@@ -74,7 +74,7 @@ public class DataGapRouteReader implements IDataToRouteReader {
 
     protected ISymmetricEngine engine;
 
-    protected boolean reading = true;
+    protected volatile boolean reading = true;
 
     protected int peekAheadCount = 1000;
 
@@ -251,6 +251,7 @@ public Data take() throws InterruptedException {
                 throw new SymmetricException("The read of the data to route queue has timed out");
             } else if (data instanceof EOD) {
                 data = null;
+                break;
             } 
 
         } while (data == null && reading);