svn commit: r713104 - /activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r713104 - /activemq/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java

davsclaus-2
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