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);
}