No commit message

JumpMind · May 21, 2010 · f4bbb8d · f4bbb8d
1 parent 23c5334
commit f4bbb8d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/route/DataToRouteReader.java b/symmetric/src/main/java/org/jumpmind/symmetric/route/DataToRouteReader.java
@@ -156,8 +156,9 @@ public Integer doInConnection(Connection c) throws SQLException, DataAccessExcep
                     reading = false;
                     boolean done = false;
                     do {
-                    	done = dataQueue.offer(new EOD());
-                    } while (!done);
+                        done = dataQueue.offer(new EOD());
+                        AppUtils.sleep(50);
+                    } while (!done && reading);
                     rs = null;
                     ps = null;
                 }