diff --git a/spring-integration-core/src/test/java/org/springframework/integration/adapter/DefaultTargetAdapterTests.java b/spring-integration-core/src/test/java/org/springframework/integration/adapter/DefaultTargetAdapterTests.java index 0b23e0d42a..3bcd0637c8 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/adapter/DefaultTargetAdapterTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/adapter/DefaultTargetAdapterTests.java @@ -37,7 +37,7 @@ import org.springframework.integration.message.Message; public class DefaultTargetAdapterTests { @Test - public void test() throws Exception { + public void testAdapterSendsToChannel() throws Exception { SynchronousQueue queue = new SynchronousQueue(); TestBean testBean = new TestBean(queue); MethodInvokingTarget target = new MethodInvokingTarget(); @@ -54,9 +54,10 @@ public class DefaultTargetAdapterTests { bus.registerChannel("channel", channel); bus.registerTargetAdapter("targetAdapter", adapter); bus.start(); - String result = queue.poll(20, TimeUnit.MILLISECONDS); + String result = queue.poll(100, TimeUnit.MILLISECONDS); assertNotNull(result); assertEquals("testing", result); + bus.stop(); }