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/16 07:04:51 UTC
[camel] 03/06: (chores) camel-mina: removed unused method parameters
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 1f35e9b4576b993823ebc15bc8173b32818a832b
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Wed Jun 15 17:38:55 2022 +0200
(chores) camel-mina: removed unused method parameters
---
.../org/apache/camel/component/mina/MinaConsumer.java | 16 ++++++++--------
.../org/apache/camel/component/mina/MinaProducer.java | 12 ++++++------
2 files changed, 14 insertions(+), 14 deletions(-)
diff --git a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
index 4cdbeb23663..0aa63db53b8 100644
--- a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
+++ b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaConsumer.java
@@ -82,14 +82,14 @@ public class MinaConsumer extends DefaultConsumer {
String protocol = configuration.getProtocol();
if (protocol.equals("tcp")) {
if (configuration.isClientMode()) {
- setupClientSocketProtocol(protocol, configuration);
+ setupClientSocketProtocol(configuration);
} else {
- setupSocketProtocol(protocol, configuration);
+ setupSocketProtocol(configuration);
}
} else if (configuration.isDatagramProtocol()) {
- setupDatagramProtocol(protocol, configuration);
+ setupDatagramProtocol(configuration);
} else if (protocol.equals("vm")) {
- setupVmProtocol(protocol, configuration);
+ setupVmProtocol(configuration);
}
}
@@ -149,7 +149,7 @@ public class MinaConsumer extends DefaultConsumer {
// Implementation methods
//-------------------------------------------------------------------------
- protected void setupVmProtocol(String uri, MinaConfiguration configuration) {
+ protected void setupVmProtocol(MinaConfiguration configuration) {
boolean minaLogger = configuration.isMinaLogger();
List<IoFilter> filters = configuration.getFilters();
@@ -169,7 +169,7 @@ public class MinaConsumer extends DefaultConsumer {
}
}
- protected void setupSocketProtocol(String uri, MinaConfiguration configuration) throws Exception {
+ protected void setupSocketProtocol(MinaConfiguration configuration) throws Exception {
LOG.debug("createSocketEndpoint");
boolean minaLogger = configuration.isMinaLogger();
List<IoFilter> filters = configuration.getFilters();
@@ -203,7 +203,7 @@ public class MinaConsumer extends DefaultConsumer {
}
}
- protected void setupClientSocketProtocol(String uri, MinaConfiguration configuration) throws Exception {
+ protected void setupClientSocketProtocol(MinaConfiguration configuration) throws Exception {
boolean minaLogger = configuration.isMinaLogger();
long timeout = configuration.getTimeout();
List<IoFilter> filters = configuration.getFilters();
@@ -267,7 +267,7 @@ public class MinaConsumer extends DefaultConsumer {
}
}
- protected void setupDatagramProtocol(String uri, MinaConfiguration configuration) {
+ protected void setupDatagramProtocol(MinaConfiguration configuration) {
boolean minaLogger = configuration.isMinaLogger();
List<IoFilter> filters = configuration.getFilters();
diff --git a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java
index 98376c54532..107e10302d6 100644
--- a/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java
+++ b/components/camel-mina/src/main/java/org/apache/camel/component/mina/MinaProducer.java
@@ -90,11 +90,11 @@ public class MinaProducer extends DefaultProducer {
String protocol = configuration.getProtocol();
if (protocol.equals("tcp")) {
- setupSocketProtocol(protocol);
+ setupSocketProtocol();
} else if (configuration.isDatagramProtocol()) {
- setupDatagramProtocol(protocol);
+ setupDatagramProtocol();
} else if (protocol.equals("vm")) {
- setupVmProtocol(protocol);
+ setupVmProtocol();
}
handler = new ResponseHandler();
connector.setHandler(handler);
@@ -293,7 +293,7 @@ public class MinaProducer extends DefaultProducer {
// Implementation methods
//-------------------------------------------------------------------------
- protected void setupVmProtocol(String uri) {
+ protected void setupVmProtocol() {
boolean minaLogger = configuration.isMinaLogger();
List<IoFilter> filters = configuration.getFilters();
@@ -312,7 +312,7 @@ public class MinaProducer extends DefaultProducer {
configureCodecFactory("MinaProducer", connector);
}
- protected void setupSocketProtocol(String uri) throws Exception {
+ protected void setupSocketProtocol() throws Exception {
boolean minaLogger = configuration.isMinaLogger();
long timeout = configuration.getTimeout();
List<IoFilter> filters = configuration.getFilters();
@@ -377,7 +377,7 @@ public class MinaProducer extends DefaultProducer {
}
}
- protected void setupDatagramProtocol(String uri) {
+ protected void setupDatagramProtocol() {
boolean minaLogger = configuration.isMinaLogger();
boolean transferExchange = configuration.isTransferExchange();
List<IoFilter> filters = configuration.getFilters();