Increased test receive timeout value.

This commit is contained in:
Mark Fisher
2008-11-19 17:09:10 +00:00
parent 85d429d29f
commit 3d13f7e954

View File

@@ -62,7 +62,7 @@ public class PollerAnnotationConsumerAdviceChainTests {
@Test
public void testAdviceChain() throws InterruptedException {
input.send(new StringMessage("test"));
Message<?> reply = output.receive(1000);
Message<?> reply = output.receive(3000);
assertEquals("TEST", reply.getPayload());
latch.await(1, TimeUnit.SECONDS);
assertEquals(0, latch.getCount());