You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/12/15 06:34:10 UTC
svn commit: r890648 -
/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java
Author: davsclaus
Date: Tue Dec 15 05:34:09 2009
New Revision: 890648
URL: http://svn.apache.org/viewvc?rev=890648&view=rev
Log:
Fixed unit test hanging on much slower boxes due JMS message expired before consuming.
Modified:
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java
Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java?rev=890648&r1=890647&r2=890648&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java (original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/JmsProducerWithJMSHeaderTest.java Tue Dec 15 05:34:09 2009
@@ -162,13 +162,15 @@
template.sendBodyAndHeaders("activemq:queue:bar?preserveMessageQos=true", "Hello World", headers);
// sleep just a little
- Thread.sleep(500);
+ Thread.sleep(50);
- Exchange bar = consumer.receive("activemq:queue:bar");
+ Exchange bar = consumer.receive("activemq:queue:bar", 5000);
assertNotNull("Should be a message on queue", bar);
template.send("activemq:queue:foo?preserveMessageQos=true", bar);
+ Thread.sleep(1000);
+
assertMockEndpointsSatisfied();
}