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

Moved start() call.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-02 01:21:22 +00:00
parent 8ecc7604d6
commit be566ea60b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/test/java/org/springframework/integration/config/ChannelAdapterParserTests.java
View File

@@ -85,13 +85,13 @@ public class ChannelAdapterParserTests extends AbstractJUnit4SpringContextTests
String beanName = "methodInvokingSource"; String beanName = "methodInvokingSource";
PollableChannel channel = (PollableChannel) this.applicationContext.getBean("queueChannel"); PollableChannel channel = (PollableChannel) this.applicationContext.getBean("queueChannel");
MessageBus bus = (MessageBus) this.applicationContext.getBean(MessageBusParser.MESSAGE_BUS_BEAN_NAME); MessageBus bus = (MessageBus) this.applicationContext.getBean(MessageBusParser.MESSAGE_BUS_BEAN_NAME);
bus.start();
assertNull(bus.lookupChannel(beanName)); assertNull(bus.lookupChannel(beanName));
Object adapter = this.applicationContext.getBean(beanName); Object adapter = this.applicationContext.getBean(beanName);
assertNotNull(adapter); assertNotNull(adapter);
assertTrue(adapter instanceof SourcePollingChannelAdapter); assertTrue(adapter instanceof SourcePollingChannelAdapter);
TestBean testBean = (TestBean) this.applicationContext.getBean("testBean"); TestBean testBean = (TestBean) this.applicationContext.getBean("testBean");
testBean.store("source test"); testBean.store("source test");
bus.start();
Message<?> message = channel.receive(1000); Message<?> message = channel.receive(1000);
assertNotNull(message); assertNotNull(message);
assertEquals("source test", testBean.getMessage()); assertEquals("source test", testBean.getMessage());