raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Reset StreamCache in getBodyAs to be able to re-read it, see #2724

Browse source
This commit is contained in:
Patrik Nordwall 2012-11-25 17:01:50 +01:00
parent 04c30fb9d0
commit 99b02c0826
3 changed files with 32 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

9
akka-camel/src/test/java/akka/camel/MessageJavaTestBase.java
View file

@ -8,6 +8,7 @@ import akka.actor.ActorSystem;
import akka.dispatch.Mapper;
import akka.japi.Function;
import org.apache.camel.NoTypeConversionAvailableException;
import org.apache.camel.converter.stream.InputStreamCache;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
@ -100,6 +101,14 @@ public class MessageJavaTestBase {
message("test1" , createMap("A", "1")).withHeaders(createMap("C", "3")));
}
@Test
public void shouldBeAbleToReReadStreamCacheBody() throws Exception {
CamelMessage msg = new CamelMessage(new InputStreamCache("test1".getBytes("utf-8")), empty);
assertEquals("test1", msg.getBodyAs(String.class, camel.context()));
// re-read
assertEquals("test1", msg.getBodyAs(String.class, camel.context()));
}
private static Set<String> createSet(String... entries) {
HashSet<String> set = new HashSet<String>();
set.addAll(Arrays.asList(entries));