Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Added tests for default splitter handling of Array and Collection payloads.

Browse Source
This commit is contained in:
Mark Fisher
2008-08-25 14:03:49 +00:00
parent dedb3294e4
commit 1f4acb82c8
2 changed files with 37 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
org.springframework.integration/src/test/java/org/springframework/integration/splitter/SplitterMessageHandlerTests.java
View File

@@ -40,6 +40,42 @@ public class SplitterMessageHandlerTests {
private SplitterTestBean testBean = new SplitterTestBean();
@Test
public void splitMessageWithArrayPayload() throws Exception {
String[] payload = new String[] { "x", "y", "z" };
Message<String[]> message = MessageBuilder.fromPayload(payload).build();
SplitterMessageHandler handler = new SplitterMessageHandler();
List<Message<?>> replies = invokeHandler(handler, message);
assertEquals(3, replies.size());
Message<?> reply1 = replies.get(0);
assertNotNull(reply1);
assertEquals("x", reply1.getPayload());
Message<?> reply2 = replies.get(1);
assertNotNull(reply2);
assertEquals("y", reply2.getPayload());
Message<?> reply3 = replies.get(2);
assertNotNull(reply3);
assertEquals("z", reply3.getPayload());
}
@Test
public void splitMessageWithCollectionPayload() throws Exception {
List<String> payload = Arrays.asList(new String[] { "x", "y", "z" });
Message<List<String>> message = MessageBuilder.fromPayload(payload).build();
SplitterMessageHandler handler = new SplitterMessageHandler();
List<Message<?>> replies = invokeHandler(handler, message);
assertEquals(3, replies.size());
Message<?> reply1 = replies.get(0);
assertNotNull(reply1);
assertEquals("x", reply1.getPayload());
Message<?> reply2 = replies.get(1);
assertNotNull(reply2);
assertEquals("y", reply2.getPayload());
Message<?> reply3 = replies.get(2);
assertNotNull(reply3);
assertEquals("z", reply3.getPayload());
}
@Test
public void splitStringToStringArray() throws Exception {
StringMessage message = new StringMessage("foo.bar");