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

INT-1622 Updated ChainParserTests

Browse Source
This commit is contained in:
David Turanski
2010-11-15 12:27:37 -05:00
parent d75f8ad21f
commit 3bb5b493b3
3 changed files with 26 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
buildSrc

Submodule buildSrc updated: 1aa2ac99e8...2e7df56522

11
spring-integration-core/src/test/java/org/springframework/integration/config/ChainParserTests-context.xml
View File

@@ -74,6 +74,15 @@
</payload-type-router>
</chain>
<chain id="chainWithClaimChecks" input-channel="claimCheckInput" output-channel="claimCheckOutput">
<claim-check-in/>
<claim-check-out/>
</chain>
<channel id="claimCheckOutput">
<queue/>
</channel>
<chain id="chainWithSendTimeout" input-channel="chainWithSendTimeoutInput" output-channel="output" send-timeout="9876">
<filter ref="typeSelector" />
<service-activator ref="testHandler" />
@@ -104,5 +113,7 @@
<beans:constructor-arg value="1" />
<beans:property name="replyMessageText" value="foo" />
</beans:bean>
<beans:bean id="messageStore" class="org.springframework.integration.store.SimpleMessageStore"/>
</beans:beans>

14
spring-integration-core/src/test/java/org/springframework/integration/config/ChainParserTests.java
View File

@@ -85,6 +85,13 @@ public class ChainParserTests {
@Autowired
private MessageChannel payloadTypeRouterInput;
@Autowired
@Qualifier("claimCheckInput")
private MessageChannel claimCheckInput;
@Autowired
@Qualifier("claimCheckOutput")
private PollableChannel claimCheckOutput;
@Autowired
private PollableChannel strings;
@@ -190,6 +197,13 @@ public class ChainParserTests {
assertEquals(9876, sendTimeout);
}
@Test //INT-1622
public void chainWithClaimChecks() {
Message<?> message = MessageBuilder.withPayload("test").build();
this.claimCheckInput.send(message);
Message<?> reply = this.claimCheckOutput.receive(0);
assertEquals(message.getPayload(), reply.getPayload());
}
public static class StubHandler extends AbstractReplyProducingMessageHandler {
@Override