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/17 10:32:07 UTC
[camel] 12/14: (chores) camel-irc: removed unused 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 169d9fa90fd1f362fe9fd94ecf8a561a9e8318d0
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri Jun 17 10:29:07 2022 +0200
(chores) camel-irc: removed unused parameters
---
.../src/main/java/org/apache/camel/component/irc/IrcBinding.java | 4 +---
.../src/main/java/org/apache/camel/component/irc/IrcComponent.java | 6 +++---
.../src/main/java/org/apache/camel/component/irc/IrcMessage.java | 2 +-
.../src/main/java/org/apache/camel/component/irc/IrcProducer.java | 2 +-
4 files changed, 6 insertions(+), 8 deletions(-)
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcBinding.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcBinding.java
index 4d19a5a52c8..9f04ec872fa 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcBinding.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcBinding.java
@@ -16,10 +16,8 @@
*/
package org.apache.camel.component.irc;
-import org.apache.camel.Exchange;
-
public class IrcBinding {
- public Object extractBodyFromIrc(Exchange exchange, IrcMessage message) {
+ public Object extractBodyFromIrc(IrcMessage message) {
String type = message.getMessageType();
String text = message.getMessage();
if (text != null) {
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcComponent.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcComponent.java
index 69aaa61428e..3e07f097df8 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcComponent.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcComponent.java
@@ -75,7 +75,7 @@ public class IrcComponent extends DefaultComponent implements SSLContextParamete
public synchronized void closeIRCConnection(IrcConfiguration configuration) {
IRCConnection connection = connectionCache.get(configuration.getCacheKey());
if (connection != null) {
- closeConnection(configuration.getCacheKey(), connection);
+ closeConnection(connection);
connectionCache.remove(configuration.getCacheKey());
}
}
@@ -139,7 +139,7 @@ public class IrcComponent extends DefaultComponent implements SSLContextParamete
return conn;
}
- public void closeConnection(String key, IRCConnection connection) {
+ public void closeConnection(IRCConnection connection) {
try {
connection.doQuit();
connection.close();
@@ -154,7 +154,7 @@ public class IrcComponent extends DefaultComponent implements SSLContextParamete
Map<String, IRCConnection> map = new HashMap<>(connectionCache);
connectionCache.clear();
for (Map.Entry<String, IRCConnection> entry : map.entrySet()) {
- closeConnection(entry.getKey(), entry.getValue());
+ closeConnection(entry.getValue());
}
super.doStop();
}
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcMessage.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcMessage.java
index 49d98f7ed7d..078c56257d3 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcMessage.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcMessage.java
@@ -125,7 +125,7 @@ public class IrcMessage extends DefaultMessage {
protected Object createBody() {
Exchange exchange = getExchange();
IrcBinding binding = ExchangeHelper.getBinding(getExchange(), IrcBinding.class);
- return binding != null ? binding.extractBodyFromIrc(exchange, this) : null;
+ return binding != null ? binding.extractBodyFromIrc(this) : null;
}
@Override
diff --git a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
index c78519060c4..e96cc1e1c0d 100644
--- a/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
+++ b/components/camel-irc/src/main/java/org/apache/camel/component/irc/IrcProducer.java
@@ -89,7 +89,7 @@ public class IrcProducer extends DefaultProducer {
LOG.debug("Reconnecting to {}:{}", getEndpoint().getConfiguration().getHostname(),
getEndpoint().getConfiguration().getNickname());
}
- getEndpoint().getComponent().closeConnection(getEndpoint().getConfiguration().getCacheKey(), connection);
+ getEndpoint().getComponent().closeConnection(connection);
connection = getEndpoint().getComponent().getIRCConnection(getEndpoint().getConfiguration());
}
connection.addIRCEventListener(listener);