diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests-context.xml b/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests-context.xml index 3059498d6e..6291982e14 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests-context.xml +++ b/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests-context.xml @@ -47,6 +47,10 @@ + + + + successMessage = MessageBuilder.withPayload("success").build(); @@ -122,6 +125,16 @@ public class ChainParserTests { assertThat(reply, is(successMessage)); } + @Test + @SuppressWarnings("unchecked") + public void chainNestingAndAggregation() throws Exception { + Message message = MessageBuilder.withPayload("test").setCorrelationId(1).setSequenceSize(1).build(); + this.aggregatorInput.send(message); + Message reply = this.output.receive(3000); + assertNotNull(reply); + assertThat((String)reply.getPayload(), is("foo")); + } + public static class StubHandler extends AbstractReplyProducingMessageHandler { @Override