Author: ningjiang
Date: Fri Jun 27 06:00:32 2008
New Revision: 672265
URL: http://svn.apache.org/viewvc?rev=672265&view=rev
Log:
Just found some typo in the AggregratedJmsRouteTest
Modified:
activemq/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
Modified:
activemq/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java?rev=672265&r1=672264&r2=672265&view=diff
==============================================================================
---
activemq/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
(original)
+++
activemq/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/AggregratedJmsRouteTest.java
Fri Jun 27 06:00:32 2008
@@ -39,7 +39,7 @@
private String multicastEndpointUri = "jms:queue:mutilcast";
/*
- * negative recieve wait timeout for jms is blocking so timeout during
processing does not hang
+ * negative receive wait timeout for jms is blocking so timeout during
processing does not hang
*/
public void testJmsBatchTimeoutExpiryWithAggregrationDelay() throws
Exception {
MockEndpoint resultEndpoint = resolveMandatoryEndpoint("mock:result",
MockEndpoint.class);
@@ -58,9 +58,9 @@
MockEndpoint resultEndpoint = resolveMandatoryEndpoint("mock:reply",
MockEndpoint.class);
resultEndpoint.expectedMessageCount(2);
- for (int i = 1; i <= 6; i++) {
+ for (int i = 1; i <= 2; i++) {
String body = "message:" + i;
- sendExchange("jms:queue:point1", body);
+ sendExchange(multicastEndpointUri, body);
}
resultEndpoint.assertIsSatisfied();