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