From 6763fcd755ab97d2a3bdf277e7082b8ae1ff9a90 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Wed, 21 May 2008 23:49:12 +0000 Subject: [PATCH] Updated intervals for timeout tests. --- .../message/RetrievalBlockingMessageStoreTests.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java b/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java index 4ef599b253..9fd5528f6b 100644 --- a/org.springframework.integration/src/test/java/org/springframework/integration/message/RetrievalBlockingMessageStoreTests.java +++ b/org.springframework.integration/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", 500); + publishWithDelay(store, "foo", "bar", 1000); 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", 500); + publishWithDelay(store, "foo", "bar", 1000); Message message = store.get("foo", 5); assertNull(message); } @@ -50,7 +50,7 @@ public class RetrievalBlockingMessageStoreTests { public void testGetWithinTimeout() { final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(10); publishWithDelay(store, "foo", "bar", 50); - Message message = store.get("foo", 500); + Message message = store.get("foo", 1000); assertNotNull(message); assertEquals("bar", message.getPayload()); assertNotNull(store.get("foo", 0)); @@ -61,7 +61,7 @@ public class RetrievalBlockingMessageStoreTests { MessageStore target = new SimpleMessageStore(10); final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(target); publishWithDelay(store, "foo", "bar", 50); - Message message = store.get("foo", 500); + Message message = store.get("foo", 1000); assertNotNull(message); assertEquals("bar", message.getPayload()); assertNotNull(store.get("foo", 0)); @@ -70,7 +70,7 @@ public class RetrievalBlockingMessageStoreTests { @Test public void testRemoveWithElapsedTimeout() { final RetrievalBlockingMessageStore store = new RetrievalBlockingMessageStore(10); - publishWithDelay(store, "foo", "bar", 500); + publishWithDelay(store, "foo", "bar", 1000); 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", 500); + publishWithDelay(store, "foo", "bar", 1000); Message message = store.remove("foo", 5); assertNull(message); }