Fixed test on slower boxes
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0f03f94f Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0f03f94f Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0f03f94f Branch: refs/heads/camel-2.12.x Commit: 0f03f94f3f99b2bf908c2345ccf1d014c8acbce4 Parents: c47953b Author: Claus Ibsen <davscl...@apache.org> Authored: Wed Sep 11 17:08:42 2013 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Wed Sep 11 17:11:54 2013 +0200 ---------------------------------------------------------------------- .../jms/JmsRequestReplyTempQueueMultipleConsumersTest.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/0f03f94f/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java ---------------------------------------------------------------------- diff --git a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java index ca93ecb..66b3ff9 100644 --- a/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java +++ b/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsRequestReplyTempQueueMultipleConsumersTest.java @@ -21,6 +21,7 @@ import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import org.apache.activemq.pool.PooledConnectionFactory; @@ -40,7 +41,7 @@ import static org.apache.camel.component.jms.JmsComponent.jmsComponentAutoAcknow */ public class JmsRequestReplyTempQueueMultipleConsumersTest extends CamelTestSupport { - private Map<String, AtomicInteger> msgsPerThread = new ConcurrentHashMap<String, AtomicInteger>(); + private final Map<String, AtomicInteger> msgsPerThread = new ConcurrentHashMap<String, AtomicInteger>(); private PooledConnectionFactory connectionFactory; @Test @@ -59,10 +60,6 @@ public class JmsRequestReplyTempQueueMultipleConsumersTest extends CamelTestSupp doSendMessages(100, 5); connectionFactory.clear(); doSendMessages(100, 5); - connectionFactory.clear(); - doSendMessages(100, 5); - connectionFactory.clear(); - doSendMessages(100, 5); } private void doSendMessages(int files, int poolSize) throws Exception { @@ -82,7 +79,7 @@ public class JmsRequestReplyTempQueueMultipleConsumersTest extends CamelTestSupp }); } - assertMockEndpointsSatisfied(); + assertMockEndpointsSatisfied(20, TimeUnit.SECONDS); executor.shutdownNow(); }
