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
index 62b879e680..62a39f5509 100644
--- 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);