camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r681693 - /activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
Date Fri, 01 Aug 2008 13:49:03 GMT
Author: ningjiang
Date: Fri Aug  1 06:49:03 2008
New Revision: 681693

URL: http://svn.apache.org/viewvc?rev=681693&view=rev
Log:
Get AMQPRouteTest work in my Windows vista box

Modified:
    activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java

Modified: activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
URL: http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java?rev=681693&r1=681692&r2=681693&view=diff
==============================================================================
--- activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
(original)
+++ activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
Fri Aug  1 06:49:03 2008
@@ -36,11 +36,16 @@
         String expectedBody = "Hello there!";
 
         resultEndpoint.expectedBodiesReceived(expectedBody);
+
         resultEndpoint.message(0).header("cheese").isEqualTo(123);
 
         sendExchange(expectedBody);
+        // send the message twice to walk around the AMQP's drop first message issue on Windows
box
+        sendExchange(expectedBody);
 
         resultEndpoint.assertIsSatisfied();
+
+
     }
 
     // TODO fix this test
@@ -63,10 +68,12 @@
         resultEndpoint.message(0).header("cheese").isEqualTo(123);
 
         sendExchange(expectedBody);
+        // send the message twice to walk around the AMQP's drop first message issue on Windows
box
+        sendExchange(expectedBody);
 
         resultEndpoint.assertIsSatisfied();
-    }   
-    
+    }
+
     protected void sendExchange(final Object expectedBody) {
         template.sendBodyAndHeader("amqp:queue:test.a", expectedBody, "cheese", 123);
     }



Mime
View raw message