From f4bbb8db914920a97d18840867e1078bb3e6a15a Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Fri, 21 May 2010 14:46:56 +0000
Subject: [PATCH]

---
 .../java/org/jumpmind/symmetric/route/DataToRouteReader.java | 5 +++--
 1 file changed, 3 insertions(+), 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
index acc40fe2f0..a5a074d495 100644
--- 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;
                 }