You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by js...@apache.org on 2007/07/09 12:09:33 UTC

svn commit: r554592 - /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/strategy/RenameFileStrategy.java

Author: jstrachan
Date: Mon Jul  9 03:09:32 2007
New Revision: 554592

URL: http://svn.apache.org/viewvc?view=rev&rev=554592
Log:
added exception throwing for CAMEL-62 if the rename doesn't work

Modified:
    activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/strategy/RenameFileStrategy.java

Modified: activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/strategy/RenameFileStrategy.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/strategy/RenameFileStrategy.java?view=diff&rev=554592&r1=554591&r2=554592
==============================================================================
--- activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/strategy/RenameFileStrategy.java (original)
+++ activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/component/file/strategy/RenameFileStrategy.java Mon Jul  9 03:09:32 2007
@@ -23,6 +23,7 @@
 import org.apache.camel.component.file.FileExchange;
 
 import java.io.File;
+import java.io.IOException;
 
 /**
  * A strategy to rename a file
@@ -62,7 +63,10 @@
         if (log.isDebugEnabled()) {
             log.debug("Renaming file: " + file + " to: " + newName);
         }
-        file.renameTo(newName);
+        boolean renamed = file.renameTo(newName);
+        if (!renamed) {
+            throw new IOException("Could not rename file from: " + file + " to " + newName);
+        }
         super.commit(endpoint, exchange, file);
     }