From b8288a0d9d1bbeda8f9312c241187ffae667517b Mon Sep 17 00:00:00 2001 From: chenson42 Date: Wed, 17 Sep 2014 20:43:12 +0000 Subject: [PATCH] 0001975: Push service continues to quickly attempt to push data on failure to read ack condition during initial load --- .../org/jumpmind/symmetric/service/impl/AbstractService.java | 4 +++- 1 file changed, 3 insertions(+), 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 index ea16b21ec5..7de130e6d1 100644 --- 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 readAcks(List 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 batchAcks = transportManager.readAcknowledgement(ackString,