From ffacaabf64be1c5620d9ca6397df47bc9ccd416c Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Sun, 13 Apr 2008 15:55:54 +0000 Subject: [PATCH] Increased timeout value for retrieval tests that should occur within the allotted timeout. --- .../message/RetrievalBlockingMessageStoreTests.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-integration-core/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java b/spring-integration-core/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java index 7444f2268f..4ef599b253 100644 --- a/spring-integration-core/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java +++ b/spring-integration-core/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java @@ -88,7 +88,7 @@ public class RetrievalBlockingMessageStoreTests { public void testRemoveWithinTimeout() { final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(10); publishWithDelay(store, "foo", "bar", 50); - Message message = store.remove("foo", 500); + Message message = store.remove("foo", 1000); assertNotNull(message); assertEquals("bar", message.getPayload()); assertNull(store.get("foo", 0)); @@ -99,7 +99,7 @@ public class RetrievalBlockingMessageStoreTests { MessageStore target = new SimpleMessageStore(10); final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(target); publishWithDelay(store, "foo", "bar", 50); - Message message = store.remove("foo", 500); + Message message = store.remove("foo", 1000); assertNotNull(message); assertEquals("bar", message.getPayload()); assertNull(store.get("foo", 0));