[jira] [Created] (CAMEL-6294) StreamCache doesn't work as expected

["Ulrich Kramer (JIRA)" <ji...@apache.org>]

Ulrich Kramer created CAMEL-6294:
------------------------------------

             Summary: StreamCache doesn't work as expected
                 Key: CAMEL-6294
                 URL: https://issues.apache.org/jira/browse/CAMEL-6294
             Project: Camel
          Issue Type: Bug
          Components: camel-core
    Affects Versions: 2.10.4
         Environment: Debian 6.0
            Reporter: Ulrich Kramer
             Fix For: 2.10.5


The following Unittests fail:


{code}
package com.sap.camel.util;

import java.io.InputStream;

import junit.framework.Assert;

import org.apache.camel.CamelContext;
import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.converter.stream.CachedOutputStream;
import org.apache.camel.impl.DefaultCamelContext;
import org.apache.camel.impl.DefaultExchange;
import org.testng.annotations.Test;

public class StreamCacheBugs {
	
	private CamelContext context;
	public void setUp() {
		
		context = new DefaultCamelContext();
	}

	@Test
	public void multipleConvertionsYielsToEmptyBody() throws Exception {
		Exchange exchange = new DefaultExchange(context);
		Message msg = exchange.getIn();
		CachedOutputStream out = new CachedOutputStream(exchange);
		out.write("Hello World".getBytes());
		msg.setBody(out.getStreamCache());
		Assert.assertEquals(msg.getBody(String.class), "Hello World");
		Assert.assertEquals(msg.getBody(String.class), "Hello World");

	}

	@Test
	public void closingInputStreamYieldsToException() throws Exception {
		Exchange exchange = new DefaultExchange(context);
		Message msg = exchange.getIn();
		CachedOutputStream out = new CachedOutputStream(exchange);
		for ( int i = 0 ; i < 10000; i++) out.write("0123456789".getBytes());
		msg.setBody(out.getStreamCache());
		InputStream in = msg.getBody(InputStream.class);
		in.read();
		in.close();
		msg.getBody(String.class);

	}
	
	@Test
	public void cachedOutputStreamsShouldBeClosable() throws Exception {
		Exchange exchange = new DefaultExchange(context);
		Message msg = exchange.getIn();
		CachedOutputStream out = new CachedOutputStream(exchange);
		for ( int i = 0 ; i < 10000; i++) out.write("0123456789".getBytes());
		msg.setBody(out.getStreamCache());
		out.close();
		msg.getBody(String.class);
	}

}
{code}

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira