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 2014/12/22 02:09:06 UTC
[2/3] camel git commit: CAMEL-8168 Added an unit test in camel-mina
CAMEL-8168 Added an unit test in camel-mina
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/cefb210e
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/cefb210e
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/cefb210e
Branch: refs/heads/master
Commit: cefb210efecfaa8659c213b45ecc63524a96b11f
Parents: 4e4cc18
Author: Willem Jiang <wi...@gmail.com>
Authored: Mon Dec 22 08:50:04 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Mon Dec 22 09:08:30 2014 +0800
----------------------------------------------------------------------
.../org/apache/camel/component/mina/MinaTcpTest.java | 15 +++++++++++++--
1 file changed, 13 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/cefb210e/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
----------------------------------------------------------------------
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
index f5a8d8e..ffa9f46 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
@@ -26,7 +26,18 @@ import org.junit.Test;
public class MinaTcpTest extends BaseMinaTest {
@Test
- public void testMinaRoute() throws Exception {
+ public void testMinaRoute1() throws Exception {
+ MockEndpoint endpoint = getMockEndpoint("mock:result");
+ Object body = "Hello there!";
+ endpoint.expectedBodiesReceived(body);
+
+ template.sendBodyAndHeader("mina:tcp://localhost:{{port}}?sync=false&minaLogger=true", body, "cheese", 123);
+
+ assertMockEndpointsSatisfied();
+ }
+
+ @Test
+ public void testMinaRoute2() throws Exception {
MockEndpoint endpoint = getMockEndpoint("mock:result");
Object body = "Hello there!";
endpoint.expectedBodiesReceived(body);
@@ -39,7 +50,7 @@ public class MinaTcpTest extends BaseMinaTest {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- from("mina:tcp://localhost:{{port}}?sync=false&minaLogger=true")
+ from("mina:tcp://0.0.0.0:{{port}}?sync=false&minaLogger=true")
.to("log:before?showAll=true").to("mock:result").to("log:after?showAll=true");
}
};