diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd b/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd index 603d87db4b..871ce57e47 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/spring-integration-core-1.0.xsd @@ -209,7 +209,7 @@ - + diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/splitter/SplitterMessageHandlerTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/splitter/SplitterMessageHandlerTests.java index e5d47ce733..e0137fb17a 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/splitter/SplitterMessageHandlerTests.java +++ b/org.springframework.integration/src/test/java/org/springframework/integration/splitter/SplitterMessageHandlerTests.java @@ -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 message = MessageBuilder.fromPayload(payload).build(); + SplitterMessageHandler handler = new SplitterMessageHandler(); + List> 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 payload = Arrays.asList(new String[] { "x", "y", "z" }); + Message> message = MessageBuilder.fromPayload(payload).build(); + SplitterMessageHandler handler = new SplitterMessageHandler(); + List> 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");