You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2008/08/01 15:49:03 UTC
svn commit: r681693 -
/activemq/camel/trunk/components/camel-amqp/src/test/java/org/apache/camel/component/amqp/AMQPRouteTest.java
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);
}