You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/06/15 12:51:41 UTC
[camel] 02/05: (chores) camel-mina: removed unnecessary calls to String.format
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit c71402e2cb1cb09b509182bd068663ac1f07b460
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Jun 15 10:41:36 2022 +0200
(chores) camel-mina: removed unnecessary calls to String.format
---
.../java/org/apache/camel/component/mina/MessageIOSessionTest.java | 2 +-
.../component/mina/MinaClientModeTcpTextlineDelimiterTest.java | 4 ++--
.../java/org/apache/camel/component/mina/MinaCustomCodecTest.java | 2 +-
.../apache/camel/component/mina/MinaDisconnectOnTimeOutTest.java | 2 +-
.../camel/component/mina/MinaDisconnectRaceConditionTest.java | 2 +-
.../java/org/apache/camel/component/mina/MinaDisconnectTest.java | 2 +-
.../apache/camel/component/mina/MinaExchangeDefaultTimeOutTest.java | 2 +-
.../org/apache/camel/component/mina/MinaExchangeTimeOutTest.java | 2 +-
.../test/java/org/apache/camel/component/mina/MinaFileTcpTest.java | 4 ++--
.../test/java/org/apache/camel/component/mina/MinaFileUdpTest.java | 4 ++--
.../java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java | 4 ++--
.../camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java | 2 +-
.../java/org/apache/camel/component/mina/MinaInOutRouteTest.java | 4 ++--
.../camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java | 2 +-
.../java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java | 6 +++---
.../apache/camel/component/mina/MinaNoResponseFromServerTest.java | 2 +-
.../camel/component/mina/MinaProducerAnotherConcurrentTest.java | 4 ++--
.../org/apache/camel/component/mina/MinaProducerConcurrentTest.java | 2 +-
.../apache/camel/component/mina/MinaProducerShutdownMockTest.java | 2 +-
.../org/apache/camel/component/mina/MinaSendToProcessorTest.java | 4 ++--
.../org/apache/camel/component/mina/MinaSpringMultipleUDPTest.java | 2 +-
.../component/mina/MinaTcpLineDelimiterUsingPlainSocketTest.java | 4 ++--
.../src/test/java/org/apache/camel/component/mina/MinaTcpTest.java | 2 +-
.../apache/camel/component/mina/MinaTcpTextlineDelimiterTest.java | 2 +-
.../apache/camel/component/mina/MinaTcpTextlineProtocolTest.java | 2 +-
.../camel/component/mina/MinaTcpWithInOutUsingPlainSocketTest.java | 2 +-
.../component/mina/MinaTcpWithIoOutProcessorExceptionTest.java | 2 +-
.../apache/camel/component/mina/MinaTransferExchangeOptionTest.java | 2 +-
.../java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java | 2 +-
.../org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java | 2 +-
.../camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java | 2 +-
.../java/org/apache/camel/component/mina/MinaVMFileTcpTest.java | 4 ++--
.../org/apache/camel/component/mina/MinaVMTextlineProtocolTest.java | 2 +-
.../camel/component/mina/MinaVMTransferExchangeOptionTest.java | 2 +-
.../src/test/java/org/apache/camel/component/mina/MinaVmTest.java | 2 +-
35 files changed, 46 insertions(+), 46 deletions(-)
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
index 50f1b3a44a8..ba9cdc73161 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MessageIOSessionTest.java
@@ -64,7 +64,7 @@ public class MessageIOSessionTest extends BaseMinaTest {
@Override
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true", getPort()))
+ fromF("mina:tcp://localhost:%1$s?textline=true", getPort())
.to("log://mytest")
.to("mock:result");
}
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
index 3eca02f27ae..44f179a2abc 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java
@@ -52,8 +52,8 @@ public class MinaClientModeTcpTextlineDelimiterTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://127.0.0.1:%1$s?sync=false&textline=true&textlineDelimiter=UNIX&clientMode=true",
- getPort()))
+ fromF("mina:tcp://127.0.0.1:%1$s?sync=false&textline=true&textlineDelimiter=UNIX&clientMode=true",
+ getPort())
.id("minaRoute")
.noAutoStartup()
.to("log:before?showAll=true")
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
index 20dfcca9c86..397dd9406e6 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaCustomCodecTest.java
@@ -120,7 +120,7 @@ public class MinaCustomCodecTest extends BaseMinaTest {
@Override
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&codec=#myCodec", getPort()))
+ fromF("mina:tcp://localhost:%1$s?sync=true&codec=#myCodec", getPort())
.transform(constant("Bye World")).to("mock:result");
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectOnTimeOutTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectOnTimeOutTest.java
index 5f01797f453..5c33a12af9f 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectOnTimeOutTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectOnTimeOutTest.java
@@ -60,7 +60,7 @@ public class MinaDisconnectOnTimeOutTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=true&timeout=30000", getPort()))
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=true&timeout=30000", getPort())
.process(e -> {
int sleep = e.getMessage().getBody(Integer.class);
Thread.sleep(sleep);
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
index d0330a72351..57aa18563ec 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectRaceConditionTest.java
@@ -60,7 +60,7 @@ public class MinaDisconnectRaceConditionTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true", getPort())).process(exchange -> {
+ fromF("mina:tcp://localhost:%1$s?sync=true&textline=true", getPort()).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
});
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
index 662c4b44f31..59c6ff6e82c 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaDisconnectTest.java
@@ -40,7 +40,7 @@ public class MinaDisconnectTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true&disconnect=true", getPort()))
+ fromF("mina:tcp://localhost:%1$s?sync=true&textline=true&disconnect=true", getPort())
.process(new Processor() {
public void process(Exchange exchange) {
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeDefaultTimeOutTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeDefaultTimeOutTest.java
index f507c86c518..c556558d13d 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeDefaultTimeOutTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeDefaultTimeOutTest.java
@@ -44,7 +44,7 @@ public class MinaExchangeDefaultTimeOutTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=true", getPort())).process(e -> {
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=true", getPort()).process(e -> {
assertEquals("Hello World", e.getIn().getBody(String.class));
// MinaProducer has a default timeout of 3 seconds so we just wait 5 seconds
// (template.requestBody is a MinaProducer behind the doors)
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeTimeOutTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeTimeOutTest.java
index 7346b2e7815..9e86a3ff8c9 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeTimeOutTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaExchangeTimeOutTest.java
@@ -50,7 +50,7 @@ public class MinaExchangeTimeOutTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=true&timeout=30000", getPort()))
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=true&timeout=30000", getPort())
.process(e -> {
assertEquals("Hello World", e.getIn().getBody(String.class));
// MinaProducer has a default timeout of 3 seconds so we just wait 2 seconds
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileTcpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileTcpTest.java
index d652afca5ba..5bfc47a8a0d 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileTcpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileTcpTest.java
@@ -37,10 +37,10 @@ public class MinaFileTcpTest extends BaseMinaTest {
public void configure() {
// lets setup a server
- from(String.format("mina:tcp://localhost:%1$s?sync=false&textline=true", getPort())).to("mock:results");
+ fromF("mina:tcp://localhost:%1$s?sync=false&textline=true", getPort()).to("mock:results");
from("file:src/test/data?noop=true&fileName=message1.txt")
- .to(String.format("mina:tcp://localhost:%1$s?sync=false&textline=true", getPort()));
+ .toF("mina:tcp://localhost:%1$s?sync=false&textline=true", getPort());
}
};
}
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileUdpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileUdpTest.java
index 758ec5df1f9..b55e26662b4 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileUdpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaFileUdpTest.java
@@ -37,10 +37,10 @@ public class MinaFileUdpTest extends BaseMinaTest {
public void configure() {
// lets setup a server
- from(String.format("mina:udp://localhost:%1$s?sync=false&textline=true", getPort())).to("mock:results");
+ fromF("mina:udp://localhost:%1$s?sync=false&textline=true", getPort()).to("mock:results");
from("file:src/test/data?noop=true")
- .to(String.format("mina:udp://localhost:%1$s?sync=false&textline=true", getPort()));
+ .toF("mina:udp://localhost:%1$s?sync=false&textline=true", getPort());
}
};
}
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
index 361a7dbb8ff..714f1a18c35 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOnlyRouteTest.java
@@ -40,14 +40,14 @@ public class MinaInOnlyRouteTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true", getPort())).process(exchange -> {
+ fromF("mina:tcp://localhost:%1$s?sync=true", getPort()).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
});
from("timer://start?period=10000&delay=2000")
.setBody(constant("Chad"))
- .to(String.format("mina:tcp://localhost:%1$s?sync=true&lazySessionCreation=true", getPort()))
+ .toF("mina:tcp://localhost:%1$s?sync=true&lazySessionCreation=true", getPort())
.to("mock:result");
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
index 4506951c3ad..42b3a4f6730 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutCloseSessionWhenCompleteTest.java
@@ -38,7 +38,7 @@ public class MinaInOutCloseSessionWhenCompleteTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true", getPort())).process(exchange -> {
+ fromF("mina:tcp://localhost:%1$s?sync=true&textline=true", getPort()).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
exchange.getMessage().setHeader(MinaConstants.MINA_CLOSE_SESSION_WHEN_COMPLETE, true);
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
index 0ba02fb241f..51a35a1e677 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTest.java
@@ -47,12 +47,12 @@ public class MinaInOutRouteTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true", getPort())).process(exchange -> {
+ fromF("mina:tcp://localhost:%1$s?sync=true", getPort()).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
});
- from("direct:in").to(String.format("mina:tcp://localhost:%1$s?sync=true&lazySessionCreation=true", getPort()))
+ from("direct:in").toF("mina:tcp://localhost:%1$s?sync=true&lazySessionCreation=true", getPort())
.to("mock:result");
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
index 98d1c88a178..688da319247 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaInOutRouteTextLineDelimiterTest.java
@@ -47,7 +47,7 @@ public class MinaInOutRouteTextLineDelimiterTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&textline=true&textlineDelimiter=MAC", getPort()))
+ fromF("mina:tcp://localhost:%1$s?sync=true&textline=true&textlineDelimiter=MAC", getPort())
.process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
index 2c98a9f0d7f..a41350108fd 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaMaxLineLengthTest.java
@@ -50,9 +50,9 @@ public class MinaMaxLineLengthTest extends BaseMinaTest {
// lets setup a server on port %1$s
// we set the sync option so we will send a reply
// and we let the request-reply be processed in the MyServerProcessor
- from(String.format(
- "mina:tcp://localhost:%1$s?sync=true&textline=true&encoderMaxLineLength=5000&decoderMaxLineLength=5000",
- getPort())).process(new MyServerProcessor());
+ fromF("mina:tcp://localhost:%1$s?sync=true&textline=true&encoderMaxLineLength=5000&decoderMaxLineLength=5000",
+ getPort())
+ .process(new MyServerProcessor());
// END SNIPPET: e1
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
index 68e0561def3..fa534aeec14 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaNoResponseFromServerTest.java
@@ -60,7 +60,7 @@ public class MinaNoResponseFromServerTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&codec=#myCodec", getPort()))
+ fromF("mina:tcp://localhost:%1$s?sync=true&codec=#myCodec", getPort())
.transform(constant("Bye World")).to("mock:result");
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
index 174ed833a2d..5752fb308ce 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerAnotherConcurrentTest.java
@@ -80,9 +80,9 @@ public class MinaProducerAnotherConcurrentTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from("direct:start").to(String.format("mina:tcp://localhost:%1$s?sync=true", getPort()));
+ from("direct:start").toF("mina:tcp://localhost:%1$s?sync=true", getPort());
- from(String.format("mina:tcp://localhost:%1$s?sync=true", getPort())).process(exchange -> {
+ fromF("mina:tcp://localhost:%1$s?sync=true", getPort()).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
}).to("mock:result");
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
index 17813f6c451..8609482a7f1 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerConcurrentTest.java
@@ -79,7 +79,7 @@ public class MinaProducerConcurrentTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true", getPort())).process(exchange -> {
+ fromF("mina:tcp://localhost:%1$s?sync=true", getPort()).process(exchange -> {
String body = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Bye " + body);
}).to("mock:result");
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerShutdownMockTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerShutdownMockTest.java
index 43fcddd93d7..44ada1d743e 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerShutdownMockTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaProducerShutdownMockTest.java
@@ -74,7 +74,7 @@ public class MinaProducerShutdownMockTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=false", getPort())).to("mock:result");
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=false", getPort()).to("mock:result");
}
};
}
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
index 95c4bdf4064..010d6c162a0 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSendToProcessorTest.java
@@ -30,7 +30,7 @@ public class MinaSendToProcessorTest extends BaseMinaTest {
@Override
public void configure() {
from("direct:start")
- .to(String.format("mina:tcp://localhost:%1$s?sync=false&lazySessionCreation=false", getPort()));
+ .toF("mina:tcp://localhost:%1$s?sync=false&lazySessionCreation=false", getPort());
}
});
@@ -48,7 +48,7 @@ public class MinaSendToProcessorTest extends BaseMinaTest {
@Override
public void configure() {
- from("direct:start").to(String.format("mina:tcp://localhost:%1$s?sync=false", getPort()));
+ from("direct:start").toF("mina:tcp://localhost:%1$s?sync=false", getPort());
}
});
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSpringMultipleUDPTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSpringMultipleUDPTest.java
index 97e59133bf4..8eaabce19a9 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSpringMultipleUDPTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaSpringMultipleUDPTest.java
@@ -50,6 +50,6 @@ public class MinaSpringMultipleUDPTest extends CamelSpringTestSupport {
// Sleep for awhile to let the messages go through.
await().atMost(3, TimeUnit.SECONDS)
- .untilAsserted(() -> assertMockEndpointsSatisfied());
+ .untilAsserted(() -> assertMockEndpointsSatisfied());
}
}
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpLineDelimiterUsingPlainSocketTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpLineDelimiterUsingPlainSocketTest.java
index 25ab3b283cd..aff0c3ee553 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpLineDelimiterUsingPlainSocketTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpLineDelimiterUsingPlainSocketTest.java
@@ -125,8 +125,8 @@ public class MinaTcpLineDelimiterUsingPlainSocketTest extends BaseMinaTest {
// use no delay for fast unit testing
errorHandler(defaultErrorHandler().maximumRedeliveries(2));
- from(String.format("mina:tcp://localhost:%1$s?textline=true&minaLogger=true&textlineDelimiter=MAC&sync=true",
- getPort()))
+ fromF("mina:tcp://localhost:%1$s?textline=true&minaLogger=true&textlineDelimiter=MAC&sync=true",
+ getPort())
.process(e -> {
String in = e.getIn().getBody(String.class);
if ("force-null-out-body".equals(in)) {
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
index 5efaafddd17..3af6d8406a1 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTest.java
@@ -51,7 +51,7 @@ public class MinaTcpTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://0.0.0.0:%1$s?sync=false&minaLogger=true", getPort()))
+ fromF("mina:tcp://0.0.0.0:%1$s?sync=false&minaLogger=true", getPort())
.to("log:before?showAll=true").to("mock:result").to("log:after?showAll=true");
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineDelimiterTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineDelimiterTest.java
index 127a7786555..7f5179ca295 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineDelimiterTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineDelimiterTest.java
@@ -40,7 +40,7 @@ public class MinaTcpTextlineDelimiterTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=false&textline=true&textlineDelimiter=UNIX", getPort()))
+ fromF("mina:tcp://localhost:%1$s?sync=false&textline=true&textlineDelimiter=UNIX", getPort())
.to("log:before?showAll=true")
.to("mock:result")
.to("log:after?showAll=true");
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineProtocolTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineProtocolTest.java
index 8a226570b88..a6a8464eec3 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineProtocolTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpTextlineProtocolTest.java
@@ -39,7 +39,7 @@ public class MinaTcpTextlineProtocolTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=false", getPort()))
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=false", getPort())
.to("log:before?showAll=true")
.to("mock:result")
.to("log:after?showAll=true");
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutUsingPlainSocketTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutUsingPlainSocketTest.java
index fbf8bd355f5..7779b917b4c 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutUsingPlainSocketTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithInOutUsingPlainSocketTest.java
@@ -134,7 +134,7 @@ public class MinaTcpWithInOutUsingPlainSocketTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=true", getPort()))
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=true", getPort())
.process(e -> {
String in = e.getIn().getBody(String.class);
if ("force-null-out-body".equals(in)) {
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithIoOutProcessorExceptionTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithIoOutProcessorExceptionTest.java
index f36e8a7c851..84b12932b34 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithIoOutProcessorExceptionTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTcpWithIoOutProcessorExceptionTest.java
@@ -47,7 +47,7 @@ public class MinaTcpWithIoOutProcessorExceptionTest extends BaseMinaTest {
// use no delay for fast unit testing
errorHandler(defaultErrorHandler().maximumRedeliveries(2));
- from(String.format("mina:tcp://localhost:%1$s?textline=true&sync=true", getPort())).process(new Processor() {
+ fromF("mina:tcp://localhost:%1$s?textline=true&sync=true", getPort()).process(new Processor() {
public void process(Exchange e) {
assertEquals("Hello World", e.getIn().getBody(String.class));
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
index 812e1854f21..a10a6771758 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaTransferExchangeOptionTest.java
@@ -100,7 +100,7 @@ public class MinaTransferExchangeOptionTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:tcp://localhost:%1$s?sync=true&encoding=UTF-8&transferExchange=true", getPort()))
+ fromF("mina:tcp://localhost:%1$s?sync=true&encoding=UTF-8&transferExchange=true", getPort())
.process(new Processor() {
public void process(Exchange e) {
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
index 41668f373c7..b0ab11f5dc3 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpNoCamelTest.java
@@ -74,7 +74,7 @@ public class MinaUdpNoCamelTest {
}
await().atMost(2, TimeUnit.SECONDS)
- .untilAsserted(() -> assertEquals(222, server.numMessagesReceived));
+ .untilAsserted(() -> assertEquals(222, server.numMessagesReceived));
}
/*
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
index c712e4b8e96..642220452c1 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpUsingTemplateTest.java
@@ -105,7 +105,7 @@ public class MinaUdpUsingTemplateTest extends BaseMinaTest {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:udp://127.0.0.1:%1$s?sync=false&minaLogger=true", getPort()))
+ fromF("mina:udp://127.0.0.1:%1$s?sync=false&minaLogger=true", getPort())
.to("mock:result");
}
};
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java
index 8ced2c29461..b48f8b21fd5 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaUdpWithInOutUsingPlainSocketTest.java
@@ -69,7 +69,7 @@ public class MinaUdpWithInOutUsingPlainSocketTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:udp://127.0.0.1:%1$s?sync=true", getPort())).process(exchange -> {
+ fromF("mina:udp://127.0.0.1:%1$s?sync=true", getPort()).process(exchange -> {
String s = exchange.getIn().getBody(String.class);
exchange.getMessage().setBody("Hello " + s);
});
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
index d97d7b20501..6dc1f17adfe 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMFileTcpTest.java
@@ -37,10 +37,10 @@ public class MinaVMFileTcpTest extends BaseMinaTest {
public void configure() {
// lets setup a server
- from(String.format("mina:vm://localhost:%1$s?sync=false&textline=true", getPort())).to("mock:results");
+ fromF("mina:vm://localhost:%1$s?sync=false&textline=true", getPort()).to("mock:results");
from("file:src/test/data?noop=true&fileName=message1.txt")
- .to(String.format("mina:vm://localhost:%1$s?sync=false&textline=true", getPort()));
+ .toF("mina:vm://localhost:%1$s?sync=false&textline=true", getPort());
}
};
}
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTextlineProtocolTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTextlineProtocolTest.java
index 86577b9ac24..198479058f0 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTextlineProtocolTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTextlineProtocolTest.java
@@ -38,7 +38,7 @@ public class MinaVMTextlineProtocolTest extends BaseMinaTest {
protected RouteBuilder createRouteBuilder() {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:vm://localhost:%1$s?textline=true&sync=false", getPort()))
+ fromF("mina:vm://localhost:%1$s?textline=true&sync=false", getPort())
.to("log:before?showAll=true")
.to("mock:result")
.to("log:after?showAll=true");
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTransferExchangeOptionTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTransferExchangeOptionTest.java
index de0a4d05684..9a8804a12a5 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTransferExchangeOptionTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVMTransferExchangeOptionTest.java
@@ -95,7 +95,7 @@ public class MinaVMTransferExchangeOptionTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:vm://localhost:%1$s?sync=true&encoding=UTF-8&transferExchange=true", getPort()))
+ fromF("mina:vm://localhost:%1$s?sync=true&encoding=UTF-8&transferExchange=true", getPort())
.process(e -> {
assertNotNull(e.getIn().getBody());
assertNotNull(e.getIn().getHeaders());
diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVmTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVmTest.java
index 8c1959c2ef2..f0cb57dc091 100644
--- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVmTest.java
+++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaVmTest.java
@@ -39,7 +39,7 @@ public class MinaVmTest extends BaseMinaTest {
return new RouteBuilder() {
public void configure() {
- from(String.format("mina:vm://localhost:%1$s?sync=false&minaLogger=true", getPort()))
+ fromF("mina:vm://localhost:%1$s?sync=false&minaLogger=true", getPort())
.to("log:before?showAll=true").to("mock:result").to("log:after?showAll=true");
}
};