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 <[email protected]>
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;
             }
         }

Reply via email to