svn commit: r982545 - /camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java

[davsclaus]

Author: davsclaus
Date: Thu Aug  5 11:23:33 2010
New Revision: 982545

URL: http://svn.apache.org/viewvc?rev=982545&view=rev
Log:
Fixed test on other boxes.

Modified:
    
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java

Modified: 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java?rev=982545&r1=982544&r2=982545&view=diff
==============================================================================
--- 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java
 (original)
+++ 
camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/temp/TemporaryQueueRouteTest.java
 Thu Aug  5 11:23:33 2010
@@ -16,13 +16,11 @@
  */
 package org.apache.camel.component.jms.temp;
 
-
 import javax.jms.ConnectionFactory;
 
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.command.ActiveMQTempQueue;
 import org.apache.camel.CamelContext;
-import org.apache.camel.ExchangePattern;
 import org.apache.camel.Message;
 import org.apache.camel.builder.RouteBuilder;
 import org.apache.camel.component.mock.MockEndpoint;
@@ -33,7 +31,6 @@ import org.junit.Test;
 
 import static 
org.apache.camel.component.jms.JmsComponent.jmsComponentClientAcknowledge;
 
-
 /**
  * @version $Revision$
  */
@@ -49,7 +46,9 @@ public class TemporaryQueueRouteTest ext
         MockEndpoint endpoint = getMockEndpoint("mock:result");
         endpoint.expectedBodiesReceived("Result");
 
-        template.sendBody(endpointUri, ExchangePattern.InOut, expectedBody);
+        Thread.sleep(1000);
+        log.info("Sending: " + expectedBody + " to: " + endpointUri);
+        template.sendBody(endpointUri, expectedBody);
 
         endpoint.assertIsSatisfied();
 
@@ -67,9 +66,11 @@ public class TemporaryQueueRouteTest ext
     }
 
     protected CamelContext createCamelContext() throws Exception {
+        deleteDirectory("activemq-data");
+
         CamelContext camelContext = super.createCamelContext();
 
-        ConnectionFactory connectionFactory = new 
ActiveMQConnectionFactory("vm://localhost?broker.persistent=false");
+        ConnectionFactory connectionFactory = new 
ActiveMQConnectionFactory("vm://localhost?broker.persistent=true");
         camelContext.addComponent("activemq", 
jmsComponentClientAcknowledge(connectionFactory));
 
         return camelContext;