You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2025/04/29 08:52:26 UTC
(camel) branch camel-4.10.x updated: CAMEL-22026: camel-jms: Should close connection when shutting down. Thanks to Kartik for reporting.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-4.10.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-4.10.x by this push:
new ad1be0584fb CAMEL-22026: camel-jms: Should close connection when shutting down. Thanks to Kartik for reporting.
ad1be0584fb is described below
commit ad1be0584fb08b4eff3328b47b52d475ae869e6d
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Tue Apr 29 10:51:14 2025 +0200
CAMEL-22026: camel-jms: Should close connection when shutting down. Thanks to Kartik for reporting.
---
.../component/sjms/consumer/SimpleMessageListenerContainer.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/SimpleMessageListenerContainer.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/SimpleMessageListenerContainer.java
index 081e98e65a0..cdc902c8998 100644
--- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/SimpleMessageListenerContainer.java
+++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/consumer/SimpleMessageListenerContainer.java
@@ -244,6 +244,12 @@ public class SimpleMessageListenerContainer extends ServiceSupport
}
}
+ @Override
+ protected void doShutdown() throws Exception {
+ closeConnection(connection);
+ this.connection = null;
+ }
+
protected void initConsumers() throws Exception {
consumerLock.lock();
try {