svn commit: r1412165 - /camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/netty/NettyAsyncRequestReplyTest.java

[da...@apache.org]

Author: davsclaus
Date: Wed Nov 21 16:10:23 2012
New Revision: 1412165

URL: http://svn.apache.org/viewvc?rev=1412165&view=rev
Log:
Fixed test

Modified:
    camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/netty/NettyAsyncRequestReplyTest.java

Modified: camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/netty/NettyAsyncRequestReplyTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/netty/NettyAsyncRequestReplyTest.java?rev=1412165&r1=1412164&r2=1412165&view=diff
==============================================================================
--- camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/netty/NettyAsyncRequestReplyTest.java (original)
+++ camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/netty/NettyAsyncRequestReplyTest.java Wed Nov 21 16:10:23 2012
@@ -43,10 +43,10 @@ public class NettyAsyncRequestReplyTest 
 
     @Test
     public void testNetty() throws Exception {
-        String out = template.requestBody("netty:tcp://localhost:" + port + "?textline=true?sync=true", "World", String.class);
+        String out = template.requestBody("netty:tcp://localhost:" + port + "?textline=true&sync=true", "World", String.class);
         assertEquals("Bye World", out);
 
-        String out2 = template.requestBody("netty:tcp://localhost:" + port + "?textline=true?sync=true", "Camel", String.class);
+        String out2 = template.requestBody("netty:tcp://localhost:" + port + "?textline=true&sync=true", "Camel", String.class);
         assertEquals("Bye Camel", out2);
     }
 
@@ -60,7 +60,7 @@ public class NettyAsyncRequestReplyTest 
             final int index = i;
             Future<String> out = executor.submit(new Callable<String>() {
                 public String call() throws Exception {
-                    String reply = template.requestBody("netty:tcp://localhost:" + port + "?textline=true?sync=true", index, String.class);
+                    String reply = template.requestBody("netty:tcp://localhost:" + port + "?textline=true&sync=true", index, String.class);
                     log.info("Sent {} received {}", index, reply);
                     assertEquals("Bye " + index, reply);
                     return reply;
@@ -72,7 +72,7 @@ public class NettyAsyncRequestReplyTest 
         // get all responses
         Set<Object> unique = new HashSet<Object>();
         for (Future<String> future : responses.values()) {
-            String reply = future.get(30, TimeUnit.SECONDS);
+            String reply = future.get(120, TimeUnit.SECONDS);
             assertNotNull("Should get a reply", reply);
             unique.add(reply);
         }
@@ -89,7 +89,7 @@ public class NettyAsyncRequestReplyTest 
             public void configure() throws Exception {
                 port = AvailablePortFinder.getNextAvailable(8000);
 
-                from("netty:tcp://localhost:" + port + "?textline=true?sync=true?reuseAddress=true?synchronous=false")
+                from("netty:tcp://localhost:" + port + "?textline=true&sync=true&reuseAddress=true&synchronous=false")
                     .to("activemq:queue:foo")
                     .log("Writing reply ${body}");