isInUse should also check inputstream and outputstream

JumpMind · Aug 6, 2014 · 82d4b6a · 82d4b6a
1 parent 0aab128
commit 82d4b6a
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagedResource.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagedResource.java
@@ -104,7 +104,9 @@ public StagedResource(long threshold, File directory, String path, StagingManage
     }
 
     public boolean isInUse() {
-        return readers.size() > 0 || writers.size() > 0;
+        return readers.size() > 0 || writers.size() > 0 || 
+                (inputStreams != null && inputStreams.size() > 0) ||
+                (outputStreams != null && outputStreams.size() > 0);
     }
 
     public boolean isFileResource() {