Author: ningjiang
Date: Thu Apr 29 08:25:58 2010
New Revision: 939227
URL: http://svn.apache.org/viewvc?rev=939227&view=rev
Log:
Fixed the an unit test error in camel-mina
Modified:
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
Modified:
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java?rev=939227&r1=939226&r2=939227&view=diff
==============================================================================
---
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
(original)
+++
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
Thu Apr 29 08:25:58 2010
@@ -17,6 +17,8 @@
package org.apache.camel.component.mina;
import org.apache.camel.ContextTestSupport;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
@@ -27,7 +29,7 @@ public class MinaVMFileTcpTest extends C
public void testMinaRoute() throws Exception {
MockEndpoint endpoint = getMockEndpoint("mock:results");
- endpoint.expectedMessageCount(1);
+ endpoint.expectedMessageCount(2);
endpoint.message(0).body().startsWith("Hello World");
assertMockEndpointsSatisfied();
@@ -39,8 +41,9 @@ public class MinaVMFileTcpTest extends C
// lets setup a server
from("mina:vm://localhost:9123?sync=false&textline=true").to("mock:results");
- from("file:src/test/data?noop=true").
-
to("mina:vm://localhost:9123?sync=false&textline=true");
+ from("file:src/test/data?noop=true&delay=2000")
+ .to("mina:vm://localhost:9123?sync=false&textline=true");
+
}
};
}