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 2021/07/13 07:38:04 UTC
[camel] branch main updated: (chores) camel-jms: remove unused
method parameter (#5829)
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
The following commit(s) were added to refs/heads/main by this push:
new d61d802 (chores) camel-jms: remove unused method parameter (#5829)
d61d802 is described below
commit d61d8021ece245d2dbdf38104c9ab274baad7206
Author: Otavio Rodolfo Piske <or...@users.noreply.github.com>
AuthorDate: Tue Jul 13 09:37:38 2021 +0200
(chores) camel-jms: remove unused method parameter (#5829)
---
.../src/main/java/org/apache/camel/component/jms/JmsConsumer.java | 4 ++--
.../src/main/java/org/apache/camel/component/jms/JmsEndpoint.java | 4 ++--
.../org/apache/camel/component/jms/reply/ReplyManagerSupport.java | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConsumer.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConsumer.java
index 98fce1d..17b3283 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConsumer.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsConsumer.java
@@ -142,7 +142,7 @@ public class JmsConsumer extends DefaultConsumer implements Suspendable {
if (listenerContainer == null) {
createMessageListenerContainer();
}
- getEndpoint().onListenerContainerStarting(listenerContainer);
+ getEndpoint().onListenerContainerStarting();
if (getEndpoint().getConfiguration().isAsyncStartListener()) {
getEndpoint().getAsyncStartStopExecutorService().submit(new Runnable() {
@@ -188,7 +188,7 @@ public class JmsConsumer extends DefaultConsumer implements Suspendable {
listenerContainer.stop();
listenerContainer.destroy();
} finally {
- getEndpoint().onListenerContainerStopped(listenerContainer);
+ getEndpoint().onListenerContainerStopped();
}
}
// null container and listener so they are fully re created if this consumer is restarted
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
index 9fb81e3..0ca85a8 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsEndpoint.java
@@ -414,11 +414,11 @@ public class JmsEndpoint extends DefaultEndpoint
return getComponent().getAsyncStartStopExecutorService();
}
- public void onListenerContainerStarting(AbstractMessageListenerContainer container) {
+ public void onListenerContainerStarting() {
runningMessageListeners.incrementAndGet();
}
- public void onListenerContainerStopped(AbstractMessageListenerContainer container) {
+ public void onListenerContainerStopped() {
runningMessageListeners.decrementAndGet();
}
diff --git a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
index 78b6e98..6204398 100644
--- a/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
+++ b/components/camel-jms/src/main/java/org/apache/camel/component/jms/reply/ReplyManagerSupport.java
@@ -277,7 +277,7 @@ public abstract class ReplyManagerSupport extends ServiceSupport implements Repl
listenerContainer.afterPropertiesSet();
log.debug("Starting reply listener container on endpoint: {}", endpoint);
- endpoint.onListenerContainerStarting(listenerContainer);
+ endpoint.onListenerContainerStarting();
listenerContainer.start();
}
@@ -291,7 +291,7 @@ public abstract class ReplyManagerSupport extends ServiceSupport implements Repl
listenerContainer.stop();
listenerContainer.destroy();
} finally {
- endpoint.onListenerContainerStopped(listenerContainer);
+ endpoint.onListenerContainerStopped();
listenerContainer = null;
}
}