Author: davsclaus
Date: Wed Aug 27 21:26:10 2008
New Revision: 689714
URL: http://svn.apache.org/viewvc?rev=689714&view=rev
Log:
CAMEL-850: added unit test
Added:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
(contents, props changed)
- copied, changed from r689707,
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
Copied:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
(from r689707,
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java)
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java?p2=activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java&p1=activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java&r1=689707&r2=689714&rev=689714&view=diff
==============================================================================
---
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
(original)
+++
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
Wed Aug 27 21:26:10 2008
@@ -23,17 +23,22 @@
import org.apache.camel.component.mock.MockEndpoint;
/**
- * Unit test to verify that MINA can be used with an InOnly MEP but still use
sync to send and receive data
+ * Unit test to verify that MINA can be used with an InOut MEP but still use
sync to send and receive data
* from a remote server.
*/
-public class MinaInOnlyRouteTest extends ContextTestSupport {
+public class MinaInOutRouteTest extends ContextTestSupport {
- public void testInOnlyUsingMina() throws Exception {
+ public void testInOutUsingMina() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedBodiesReceived("Bye Claus");
+ // we should preserve headers
+ mock.expectedHeaderReceived("city", "Copenhagen");
mock.setResultWaitTime(5000);
+ Object out = template.requestBodyAndHeader("direct:in", "Claus",
"city", "Copenhagen");
+
assertMockEndpointsSatisifed();
+ assertEquals("Bye Claus", out);
}
@Override
@@ -47,10 +52,10 @@
}
});
- from("timer://start?period=10000&delay=2000")
- .setBody(constant("Claus"))
-
.to("mina:tcp://localhost:8080?sync=true").to("mock:result");
+ from("direct:in")
+ .to("mina:tcp://localhost:8080?sync=true")
+ .to("mock:result");
}
};
}
-}
+}
\ No newline at end of file
Propchange:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
------------------------------------------------------------------------------
svn:keywords = Rev Date
Propchange:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
------------------------------------------------------------------------------
svn:mergeinfo =
