svn commit: r829007 - /camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java

[davsclaus]

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);
+                    }
                 }
             }