You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/10/23 13:38:12 UTC
svn commit: r829007 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java
Author: davsclaus
Date: Fri Oct 23 11:38:12 2009
New Revision: 829007
URL: http://svn.apache.org/viewvc?rev=829007&view=rev
Log:
CAMEL-2058: Fail if existing file cannot be deleted.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java?rev=829007&r1=829006&r2=829007&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java Fri Oct 23 11:38:12 2009
@@ -100,7 +100,10 @@
if (log.isTraceEnabled()) {
log.trace("Deleting existing file: " + tempTarget);
}
- operations.deleteFile(target);
+ if (!operations.deleteFile(target)) {
+ throw new GenericFileOperationFailedException("Cannot delete file: " + target);
+ }
+
}
}
@@ -109,7 +112,9 @@
if (log.isTraceEnabled()) {
log.trace("Deleting existing temp file: " + tempTarget);
}
- operations.deleteFile(tempTarget);
+ if (!operations.deleteFile(tempTarget)) {
+ throw new GenericFileOperationFailedException("Cannot delete file: " + tempTarget);
+ }
}
}