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");
