INT-521

org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests-context.xml

@@ -9,6 +9,10 @@
 
 	<channel id="filterInput"/>
 
+	<channel id="pollableInput">
+		<queue/>
+	</channel>
+
 	<channel id="output">
 		<queue/>
 	</channel>
@@ -30,6 +34,14 @@
 		<service-activator ref="testHandler"/>
 	</chain>
 
+	<chain input-channel="pollableInput" output-channel="output">
+		<poller>
+			<interval-trigger interval="10000"/>
+		</poller>
+		<filter ref="typeSelector"/>
+		<service-activator ref="testHandler"/>
+	</chain>
+
 	<beans:bean id="testHeaderValue" class="java.lang.Integer">
 		<beans:constructor-arg value="123"/>
 	</beans:bean>

org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests.java

@@ -41,6 +41,10 @@ public class ChainParserTests extends AbstractJUnit4SpringContextTests {
 	@Qualifier("filterInput")
 	private MessageChannel filterInput;
 
+	@Autowired
+	@Qualifier("pollableInput")
+	private MessageChannel pollableInput;
+
 	@Autowired
 	@Qualifier("headerEnricherInput")
 	private MessageChannel headerEnricherInput;
@@ -83,4 +87,13 @@ public class ChainParserTests extends AbstractJUnit4SpringContextTests {
 		assertEquals(123, reply.getHeaders().get("testRef"));
 	}
 
+	@Test
+	public void chainWithPollableInput() {	
+		Message<?> message = MessageBuilder.withPayload("test").build();
+		this.pollableInput.send(message);
+		Message<?> reply = this.output.receive(3000);
+		assertNotNull(reply);
+		assertEquals("foo", reply.getPayload());
+	}
+
 }