0001141: Prevent invalid warning that expected ack was not received

JumpMind · Mar 26, 2013 · 3e7b6a5 · 3e7b6a5
1 parent 8a43bf8
commit 3e7b6a5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/PushService.java
@@ -189,7 +189,9 @@ private void pushToNode(Node remote, RemoteNodeStatus status) {
             if (extractedBatches.size() > 0) {
                 Set<Long> batchIds = new HashSet<Long>(extractedBatches.size());
                 for (OutgoingBatch outgoingBatch : extractedBatches) {
-                    batchIds.add(outgoingBatch.getBatchId());
+                    if (outgoingBatch.getStatus() == OutgoingBatch.Status.LD) {
+                       batchIds.add(outgoingBatch.getBatchId());
+                    }
                 }
 
                 log.info("Push data sent to {}", remote);