Don't re-extract if a network transfer failed.

JumpMind · Apr 28, 2011 · e128495 · e128495
1 parent 679e360
commit e128495
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ymmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/...ymmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -455,14 +455,14 @@ public List<OutgoingBatch> extract(Node node, IOutgoingTransport targetTransport
                             fileWriter.reset();
 
                             File previouslyExtracted = extractedBatchesHandle.get(currentBatch.getBatchId());
-                            if (previouslyExtracted == null) {
+                            if (previouslyExtracted != null && previouslyExtracted.exists()) {
+                                log.info("DataExtractorUsingAlreadyExtractedBatch", currentBatch.getBatchId());
+                                fileWriter.setFile(previouslyExtracted);
+                            } else {
                                 outgoingBatch.setStatus(OutgoingBatch.Status.QY);
                                 outgoingBatch.setExtractCount(outgoingBatch.getExtractCount() + 1);
                                 outgoingBatchService.updateOutgoingBatch(outgoingBatch);
                                 databaseExtract(node, outgoingBatch, handler);
-                            } else {
-                                log.info("DataExtractorUsingAlreadyExtractedBatch", currentBatch.getBatchId());
-                                fileWriter.setFile(previouslyExtracted);
                             }
                             outgoingBatch.setStatus(OutgoingBatch.Status.SE);
                             outgoingBatch.setSentCount(outgoingBatch.getSentCount() + 1);