diff --git a/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-1.0.xsd b/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-1.0.xsd
index 2d430c096d..d19b57f66a 100644
--- a/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-1.0.xsd
+++ b/org.springframework.integration/src/main/resources/org/springframework/integration/config/xml/spring-integration-1.0.xsd
@@ -686,7 +686,7 @@
-
+
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 6291982e14..8f076136e2 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
@@ -6,7 +6,11 @@
http://www.springframework.org/schema/integration
http://www.springframework.org/schema/integration/spring-integration-1.0.xsd">
-
+
+
+
+
+
@@ -32,7 +36,7 @@
-
+
@@ -40,6 +44,15 @@
+
+
+
+
+
+
+
+
+
@@ -69,5 +82,5 @@
class="org.springframework.integration.config.TestHandler">
-
+
diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests.java
index 21b5b30074..16e4ca00c4 100644
--- a/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests.java
+++ b/org.springframework.integration/src/test/java/org/springframework/integration/config/ChainParserTests.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2002-2008 the original author or authors.
+ * Copyright 2002-2009 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -16,11 +16,9 @@
package org.springframework.integration.config;
-import static org.hamcrest.CoreMatchers.is;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertThat;
import java.util.List;
@@ -52,8 +50,12 @@ public class ChainParserTests {
private MessageChannel filterInput;
@Autowired
- @Qualifier("pollableInput")
- private MessageChannel pollableInput;
+ @Qualifier("pollableInput1")
+ private MessageChannel pollableInput1;
+
+ @Autowired
+ @Qualifier("pollableInput2")
+ private MessageChannel pollableInput2;
@Autowired
@Qualifier("headerEnricherInput")
@@ -107,14 +109,23 @@ public class ChainParserTests {
}
@Test
- public void chainWithPollableInput() {
+ public void chainWithPollableInput() {
Message> message = MessageBuilder.withPayload("test").build();
- this.pollableInput.send(message);
+ this.pollableInput1.send(message);
Message> reply = this.output.receive(3000);
assertNotNull(reply);
assertEquals("foo", reply.getPayload());
}
-
+
+ @Test
+ public void chainWithPollerReference() {
+ Message> message = MessageBuilder.withPayload("test").build();
+ this.pollableInput2.send(message);
+ Message> reply = this.output.receive(3000);
+ assertNotNull(reply);
+ assertEquals("foo", reply.getPayload());
+ }
+
@Test
@SuppressWarnings("unchecked")
public void chainHandlerBean() throws Exception {