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

Added timeout to prevent indefinitely blocking tests.

Browse Source
This commit is contained in:
Mark Fisher
2007-12-27 19:11:25 +00:00
parent 076a88eb41
commit 5c5bcdf2fc
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-core/src/test/java/org/springframework/integration/bus/MessageBusTests.java
View File

@@ -47,7 +47,7 @@ public class MessageBusTests {
endpoint.setDefaultOutputChannelName("targetChannel"); endpoint.setDefaultOutputChannelName("targetChannel");
bus.registerEndpoint("endpoint", endpoint); bus.registerEndpoint("endpoint", endpoint);
bus.start(); bus.start();
Message<?> result = targetChannel.receive(); Message<?> result = targetChannel.receive(1000);
assertEquals("test", result.getPayload()); assertEquals("test", result.getPayload());
bus.stop(); bus.stop();
} }

3
spring-integration-core/src/test/java/org/springframework/integration/endpoint/annotation/MessageEndpointAnnotationPostProcessorTests.java
View File

@@ -19,6 +19,7 @@ package org.springframework.integration.endpoint.annotation;
import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertEquals;
import org.junit.Test; import org.junit.Test;
import org.springframework.context.support.AbstractApplicationContext; import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.integration.channel.MessageChannel; import org.springframework.integration.channel.MessageChannel;
@@ -37,7 +38,7 @@ public class MessageEndpointAnnotationPostProcessorTests {
MessageChannel inputChannel = (MessageChannel) context.getBean("inputChannel"); MessageChannel inputChannel = (MessageChannel) context.getBean("inputChannel");
MessageChannel outputChannel = (MessageChannel) context.getBean("outputChannel"); MessageChannel outputChannel = (MessageChannel) context.getBean("outputChannel");
inputChannel.send(new GenericMessage<String>(1, "world")); inputChannel.send(new GenericMessage<String>(1, "world"));
Message<String> message = outputChannel.receive(); Message<String> message = outputChannel.receive(1000);
assertEquals("hello world", message.getPayload()); assertEquals("hello world", message.getPayload());
context.stop(); context.stop();
} }