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 2010/05/13 07:15:33 UTC
svn commit: r943803 - in
/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina:
MinaCustomCodecTest.java MinaProducerConcurrentTest.java
Author: ningjiang
Date: Thu May 13 05:15:33 2010
New Revision: 943803
URL: http://svn.apache.org/viewvc?rev=943803&view=rev
Log:
Try to fix the Address already in use exception on other Box of TC
Modified:
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
Modified: camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java?rev=943803&r1=943802&r2=943803&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java (original)
+++ camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java Thu May 13 05:15:33 2010
@@ -35,9 +35,9 @@ import org.apache.mina.filter.codec.Prot
*/
public class MinaCustomCodecTest extends ContextTestSupport {
- protected String uri = "mina:tcp://localhost:5130?sync=true&codec=#myCodec";
+ protected String uri = "mina:tcp://localhost:9130?sync=true&codec=#myCodec";
- protected String badUri = "mina:tcp://localhost:5130?sync=true&codec=#XXX";
+ protected String badUri = "mina:tcp://localhost:9130?sync=true&codec=#XXX";
public void testMyCodec() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
Modified: camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java?rev=943803&r1=943802&r2=943803&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java (original)
+++ camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java Thu May 13 05:15:33 2010
@@ -52,7 +52,7 @@ public class MinaProducerConcurrentTest
final int index = i;
Future out = executor.submit(new Callable<Object>() {
public Object call() throws Exception {
- return template.requestBody("mina:tcp://localhost:8080?sync=true", index, String.class);
+ return template.requestBody("mina:tcp://localhost:9090?sync=true", index, String.class);
}
});
responses.put(index, out);
@@ -75,7 +75,7 @@ public class MinaProducerConcurrentTest
protected RouteBuilder createRouteBuilder() throws Exception {
return new RouteBuilder() {
public void configure() throws Exception {
- from("mina:tcp://localhost:8080?sync=true").process(new Processor() {
+ from("mina:tcp://localhost:9090?sync=true").process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
exchange.getOut().setBody("Bye " + body);