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 2011/11/16 13:24:06 UTC
svn commit: r1202659 -
/camel/trunk/camel-core/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java
Author: davsclaus
Date: Wed Nov 16 12:24:06 2011
New Revision: 1202659
URL: http://svn.apache.org/viewvc?rev=1202659&view=rev
Log:
CAMEL-4686: Using buffered input stream for file input stream cache. Thanks to Metatech for the patch.
Modified:
camel/trunk/camel-core/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java
URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java?rev=1202659&r1=1202658&r2=1202659&view=diff
==============================================================================
--- camel/trunk/camel-core/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java (original)
+++ camel/trunk/camel-core/src/main/java/org/apache/camel/converter/stream/FileInputStreamCache.java Wed Nov 16 12:24:06 2011
@@ -16,6 +16,7 @@
*/
package org.apache.camel.converter.stream;
+import java.io.BufferedInputStream;
import java.io.Closeable;
import java.io.File;
import java.io.FileInputStream;
@@ -34,7 +35,7 @@ public class FileInputStreamCache extend
public FileInputStreamCache(File file) throws FileNotFoundException {
this.file = file;
- this.stream = new FileInputStream(file);
+ this.stream = new BufferedInputStream(new FileInputStream(file));
}
@Override
@@ -50,7 +51,7 @@ public class FileInputStreamCache extend
// reset by closing and creating a new stream based on the file
close();
// reset by creating a new stream based on the file
- stream = new FileInputStream(file);
+ stream = new BufferedInputStream(new FileInputStream(file));
} catch (Exception e) {
throw new RuntimeCamelException("Cannot reset stream from file " + file, e);
}