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