0001975: Push service continues to quickly attempt to push data on fa…

…ilure to read ack condition during initial load
JumpMind · Sep 17, 2014 · b8288a0 · b8288a0
1 parent e42aee9
commit b8288a0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/AbstractService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/AbstractService.java
@@ -37,6 +37,7 @@
 import org.jumpmind.db.platform.IDatabasePlatform;
 import org.jumpmind.db.sql.ISqlTemplate;
 import org.jumpmind.db.sql.ISqlTransaction;
+import org.jumpmind.symmetric.SymmetricException;
 import org.jumpmind.symmetric.common.ParameterConstants;
 import org.jumpmind.symmetric.common.TableConstants;
 import org.jumpmind.symmetric.db.ISymmetricDialect;
@@ -308,7 +309,8 @@ protected  List<BatchAck> readAcks(List<OutgoingBatch> batches, IOutgoingWithRes
         } while (line != null);
 
         if (StringUtils.isBlank(ackString)) {
-            log.error("Did not receive an acknowledgement for the batches sent");
+            throw new SymmetricException("Did not receive an acknowledgement for the batches sent.  "
+                    + "The 'ack string' was: '%s' and the 'extended ack string' was: '%s'", ackString, ackExtendedString);
         }
 
         List<BatchAck> batchAcks = transportManager.readAcknowledgement(ackString,