0002603: Retry batches from staging instead of sending them again

JumpMind · Jun 2, 2016 · 3fad3ec · 3fad3ec
1 parent 2b14b93
commit 3fad3ec
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -575,8 +575,9 @@ public FutureOutgoingBatch call() throws Exception {
                                 FutureOutgoingBatch outgoingBatch = new FutureOutgoingBatch(extractBatch, false);
                                 if (!status.shouldExtractSkip) {
                                     try {
+                                        boolean isRetry = isRetry(extractBatch, targetNode);
                                         outgoingBatch = new FutureOutgoingBatch(extractOutgoingBatch(processInfo, targetNode, 
-                                                dataWriter, extractBatch, streamToFileEnabled, true, mode), isRetry(extractBatch, targetNode));
+                                                dataWriter, extractBatch, streamToFileEnabled, true, mode), isRetry);
                                         status.batchExtractCount++;
                                         status.byteExtractCount += extractBatch.getByteCount();