0002959: BatchStagingManager deleting incoming files from staging that

are not yet processed
JumpMind · Jan 12, 2017 · 92f3268 · 92f3268
1 parent 250a7da
commit 92f3268
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/io/stage/BatchStagingManager.java
@@ -51,7 +51,7 @@ public long clean(long ttlInMs) {
                  * resource could have deleted itself between the time the keys
                  * were cloned and now
                  */
-                if (resource != null) {
+                if (resource != null && !resource.isInUse()) {
                     boolean resourceIsOld = (System.currentTimeMillis() - resource.getLastUpdateTime()) > ttlInMs;
                     if (path[0].equals(STAGING_CATEGORY_OUTGOING)) {
                         try {