Author: davsclaus
Date: Tue Nov 11 10:46:30 2008
New Revision: 713104
URL: http://svn.apache.org/viewvc?rev=713104&view=rev
Log:
CAMEL-656: Polished mina code
Modified:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
Modified:
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
URL:
http://svn.apache.org/viewvc/activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java?rev=713104&r1=713103&r2=713104&view=diff
==============================================================================
---
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
(original)
+++
activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
Tue Nov 11 10:46:30 2008
@@ -33,7 +33,7 @@
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedBodiesReceived("Hello World");
- template.sendBody("mina:tcp://localhost:6200?textline=true", "Hello
World");
+
template.sendBody("mina:tcp://localhost:6200?textline=true&sync=false", "Hello
World");
assertMockEndpointsSatisfied();
// END SNIPPET: e2
@@ -41,7 +41,7 @@
public void testSendTextlineSyncText() throws Exception {
// START SNIPPET: e4
- String response =
(String)template.sendBody("mina:tcp://localhost:6201?textline=true&sync=true",
"World");
+ String response =
(String)template.requestBody("mina:tcp://localhost:6201?textline=true&sync=true",
"World");
assertEquals("Bye World", response);
// END SNIPPET: e4
}
@@ -50,7 +50,7 @@
return new RouteBuilder() {
public void configure() throws Exception {
// START SNIPPET: e1
-
from("mina:tcp://localhost:6200?textline=true").to("mock:result");
+
from("mina:tcp://localhost:6200?textline=true&sync=false").to("mock:result");
// END SNIPPET: e1
// START SNIPPET: e3
