0003094: Status of batches set to resend when error on channel

JumpMind · May 5, 2017 · 5c87941 · 5c87941
1 parent 859d5e1
commit 5c87941
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java
@@ -986,8 +986,8 @@ protected IDataWriter chooseDataWriter(Batch batch) {
                             }
                             resource.setState(State.DONE);
                         }
-                    } else {
-                        log.info("The batch {} was missing in staging.  Setting status to resend", batch.getNodeBatchId());
+                    } else if (resource == null || !resource.exists()) {
+                        log.info("The batch {} was missing in staging.  Setting status to resend.", batch.getNodeBatchId());
                         incomingBatch = new IncomingBatch(batch);
                         incomingBatch.setStatus(Status.RS);
                         incomingBatchService.updateIncomingBatch(incomingBatch);