From 167da2f28c953a856901b2e203eb532f0078a7bd Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Sat, 12 Apr 2008 16:12:28 +0000 Subject: [PATCH] Increased delay for publishing to the MessageStore when testing blocking retrieval that should timeout. --- .../message/RetrievalBlockingMessageStoreTests.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 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 24026954cb..7444f2268f 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 @@ -32,7 +32,7 @@ public class RetrievalBlockingMessageStoreTests { @Test public void testGetWithElapsedTimeout() { final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(10); - publishWithDelay(store, "foo", "bar", 100); + publishWithDelay(store, "foo", "bar", 500); Message message = store.get("foo", 5); assertNull(message); } @@ -41,7 +41,7 @@ public class RetrievalBlockingMessageStoreTests { public void testWrappedTargetGetWithElapsedTimeout() { MessageStore target = new SimpleMessageStore(10); final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(target); - publishWithDelay(store, "foo", "bar", 100); + publishWithDelay(store, "foo", "bar", 500); Message message = store.get("foo", 5); assertNull(message); } @@ -70,7 +70,7 @@ public class RetrievalBlockingMessageStoreTests { @Test public void testRemoveWithElapsedTimeout() { final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(10); - publishWithDelay(store, "foo", "bar", 100); + publishWithDelay(store, "foo", "bar", 500); Message message = store.remove("foo", 5); assertNull(message); } @@ -79,7 +79,7 @@ public class RetrievalBlockingMessageStoreTests { public void testWrappedMessageStoreRemoveWithElapsedTimeout() { MessageStore target = new SimpleMessageStore(10); final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(target); - publishWithDelay(store, "foo", "bar", 100); + publishWithDelay(store, "foo", "bar", 500); Message message = store.remove("foo", 5); assertNull(message); }