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/05 05:05:52 UTC
svn commit: r941141 - in
/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina:
MessageIOSessionTest.java MinaConsumerTest.java MinaCustomCodecTest.java
MinaEncodingTest.java
Author: ningjiang
Date: Wed May 5 03:05:52 2010
New Revision: 941141
URL: http://svn.apache.org/viewvc?rev=941141&view=rev
Log:
Try to fix the Address already in use errors in Mac OSX of TC
Modified:
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
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/MinaEncodingTest.java
Modified: camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java?rev=941141&r1=941140&r2=941141&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java (original)
+++ camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java Wed May 5 03:05:52 2010
@@ -34,7 +34,7 @@ public class MessageIOSessionTest extend
public void testIoSession() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(1);
- template.sendBody("mina:tcp://localhost:6200?textline=true&sync=false", "Hello World");
+ template.sendBody("mina:tcp://localhost:9200?textline=true&sync=false", "Hello World");
assertMockEndpointsSatisfied();
Exchange exchange = mock.getExchanges().get(0);
@@ -46,7 +46,7 @@ public class MessageIOSessionTest extend
public void testLocalAndRemoteAddressHeaders() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
mock.expectedMessageCount(1);
- template.sendBody("mina:tcp://localhost:6200?textline=true&sync=false", "Hello World");
+ template.sendBody("mina:tcp://localhost:9200?textline=true&sync=false", "Hello World");
assertMockEndpointsSatisfied();
Message message = mock.getExchanges().get(0).getIn();
@@ -61,7 +61,7 @@ public class MessageIOSessionTest extend
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("mina:tcp://localhost:6200?textline=true&sync=false")
+ from("mina:tcp://localhost:9200?textline=true&sync=false")
.to("log://mytest")
.to("mock:result");
}
Modified: camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java?rev=941141&r1=941140&r2=941141&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java (original)
+++ camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaConsumerTest.java Wed May 5 03:05:52 2010
@@ -41,7 +41,7 @@ public class MinaConsumerTest extends Co
public void testSendTextlineSyncText() throws Exception {
// START SNIPPET: e4
- String response = (String)template.requestBody("mina:tcp://localhost:6201?textline=true&sync=true", "World");
+ String response = (String)template.requestBody("mina:tcp://localhost:9201?textline=true&sync=true", "World");
assertEquals("Bye World", response);
// END SNIPPET: e4
}
@@ -54,7 +54,7 @@ public class MinaConsumerTest extends Co
// END SNIPPET: e1
// START SNIPPET: e3
- from("mina:tcp://localhost:6201?textline=true&sync=true").process(new Processor() {
+ from("mina:tcp://localhost:9201?textline=true&sync=true").process(new Processor() {
public void process(Exchange exchange) throws Exception {
String body = exchange.getIn().getBody(String.class);
exchange.getOut().setBody("Bye " + body);
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=941141&r1=941140&r2=941141&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 Wed May 5 03:05:52 2010
@@ -35,9 +35,9 @@ import org.apache.mina.filter.codec.Prot
*/
public class MinaCustomCodecTest extends ContextTestSupport {
- protected String uri = "mina:tcp://localhost:11300?sync=true&codec=#myCodec";
+ protected String uri = "mina:tcp://localhost:5130?sync=true&codec=#myCodec";
- protected String badUri = "mina:tcp://localhost:11300?sync=true&codec=#XXX";
+ protected String badUri = "mina:tcp://localhost:5130?sync=true&codec=#XXX";
public void testMyCodec() throws Exception {
MockEndpoint mock = getMockEndpoint("mock:result");
@@ -51,7 +51,7 @@ public class MinaCustomCodecTest extends
}
public void testTCPEncodeUTF8InputIsString() throws Exception {
- final String myUri = "mina:tcp://localhost:9080?encoding=UTF-8&sync=false";
+ final String myUri = "mina:tcp://localhost:9085?encoding=UTF-8&sync=false";
this.context.addRoutes(new RouteBuilder() {
public void configure() {
from(myUri).to("mock:result");
Modified: camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java?rev=941141&r1=941140&r2=941141&view=diff
==============================================================================
--- camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java (original)
+++ camel/trunk/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaEncodingTest.java Wed May 5 03:05:52 2010
@@ -34,7 +34,7 @@ import org.apache.camel.component.mock.M
public class MinaEncodingTest extends ContextTestSupport {
public void testTCPEncodeUTF8InputIsBytes() throws Exception {
- final String uri = "mina:tcp://localhost:9080?encoding=UTF-8&sync=false";
+ final String uri = "mina:tcp://localhost:9085?encoding=UTF-8&sync=false";
this.context.addRoutes(new RouteBuilder() {
public void configure() {
from(uri).to("mock:result");
@@ -54,7 +54,7 @@ public class MinaEncodingTest extends Co
}
public void testTCPEncodeUTF8InputIsString() throws Exception {
- final String uri = "mina:tcp://localhost:9080?encoding=UTF-8&sync=false";
+ final String uri = "mina:tcp://localhost:9085?encoding=UTF-8&sync=false";
this.context.addRoutes(new RouteBuilder() {
public void configure() {
from(uri).to("mock:result");
@@ -74,7 +74,7 @@ public class MinaEncodingTest extends Co
}
public void testTCPEncodeUTF8TextLineInputIsString() throws Exception {
- final String uri = "mina:tcp://localhost:9080?textline=true&encoding=UTF-8&sync=false";
+ final String uri = "mina:tcp://localhost:9085?textline=true&encoding=UTF-8&sync=false";
this.context.addRoutes(new RouteBuilder() {
public void configure() {
from(uri).to("mock:result");