Repository: camel Updated Branches: refs/heads/master cfdf18542 -> d1121a7b4
CAMEL-8688: Stream cache now keeps track on number of copies that was spooled to disk, so when the temp file is deleted its only deleted when no longer in use. A file can be shared if using wire tap etc. Thanks to Franz Forsthofer for the patch. Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0fa7d693 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0fa7d693 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0fa7d693 Branch: refs/heads/master Commit: 0fa7d6935b890cf8020dffede6145fe8fb7d376f Parents: a535a47 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon May 4 19:31:15 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon May 4 19:31:30 2015 +0200 ---------------------------------------------------------------------- .../component/netty4/http/NettyChannelBufferStreamCache.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/0fa7d693/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyChannelBufferStreamCache.java ---------------------------------------------------------------------- diff --git a/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyChannelBufferStreamCache.java b/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyChannelBufferStreamCache.java index d8a183f..70635f0 100644 --- a/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyChannelBufferStreamCache.java +++ b/components/camel-netty4-http/src/main/java/org/apache/camel/component/netty4/http/NettyChannelBufferStreamCache.java @@ -21,6 +21,7 @@ import java.io.InputStream; import java.io.OutputStream; import io.netty.buffer.ByteBuf; +import org.apache.camel.Exchange; import org.apache.camel.StreamCache; import org.apache.camel.util.IOHelper; @@ -87,7 +88,7 @@ public final class NettyChannelBufferStreamCache extends InputStream implements } @Override - public StreamCache copy() throws IOException { + public StreamCache copy(Exchange exchange) throws IOException { return new NettyChannelBufferStreamCache(buffer.copy()); }
