You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by co...@apache.org on 2020/07/08 09:18:06 UTC
[cxf] branch 3.3.x-fixes updated: CXF-8310 - JMS transport with
flag oneSessionPerConnection causes reconnection to not work. Thanks to
Dieter Brandt for the patch.
This is an automated email from the ASF dual-hosted git repository.
coheigea pushed a commit to branch 3.3.x-fixes
in repository https://gitbox.apache.org/repos/asf/cxf.git
The following commit(s) were added to refs/heads/3.3.x-fixes by this push:
new 8fd3d2e CXF-8310 - JMS transport with flag oneSessionPerConnection causes reconnection to not work. Thanks to Dieter Brandt for the patch.
8fd3d2e is described below
commit 8fd3d2ef1c79352048d4bf7ab435accc2a78483a
Author: Colm O hEigeartaigh <co...@apache.org>
AuthorDate: Wed Jul 8 10:12:26 2020 +0100
CXF-8310 - JMS transport with flag oneSessionPerConnection causes reconnection to not work. Thanks to Dieter Brandt for the patch.
(cherry picked from commit ef6971322ae5dfcaf6e533b6b686275a58a648eb)
---
.../src/main/java/org/apache/cxf/transport/jms/JMSDestination.java | 2 +-
.../cxf/transport/jms/util/PollingMessageListenerContainer.java | 6 ++++++
2 files changed, 7 insertions(+), 1 deletion(-)
diff --git a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
index 53176f1..1aa3921 100644
--- a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
+++ b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSDestination.java
@@ -151,7 +151,7 @@ public class JMSDestination extends AbstractMultiplexDestination implements Mess
Destination destination = jmsConfig.getTargetDestination(session);
container = new PollingMessageListenerContainer(connection, destination, this, exListener);
} else {
- container = new PollingMessageListenerContainer(jmsConfig, false, this);
+ container = new PollingMessageListenerContainer(jmsConfig, false, this, exListener);
}
container.setConcurrentConsumers(jmsConfig.getConcurrentConsumers());
diff --git a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/util/PollingMessageListenerContainer.java b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/util/PollingMessageListenerContainer.java
index 51a1fa4..e355515 100644
--- a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/util/PollingMessageListenerContainer.java
+++ b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/util/PollingMessageListenerContainer.java
@@ -46,9 +46,15 @@ public class PollingMessageListenerContainer extends AbstractMessageListenerCont
public PollingMessageListenerContainer(JMSConfiguration jmsConfig, boolean isReply,
MessageListener listenerHandler) {
+ this(jmsConfig, isReply, listenerHandler, null);
+ }
+
+ public PollingMessageListenerContainer(JMSConfiguration jmsConfig, boolean isReply,
+ MessageListener listenerHandler, ExceptionListener exceptionListener) {
this.jmsConfig = jmsConfig;
this.reply = isReply;
this.listenerHandler = listenerHandler;
+ this.exceptionListener = exceptionListener;
}
public PollingMessageListenerContainer(Connection connection, Destination destination,