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:13:01 UTC
[cxf] branch master 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 master
in repository https://gitbox.apache.org/repos/asf/cxf.git
The following commit(s) were added to refs/heads/master by this push:
new ef69713 CXF-8310 - JMS transport with flag oneSessionPerConnection causes reconnection to not work. Thanks to Dieter Brandt for the patch.
ef69713 is described below
commit ef6971322ae5dfcaf6e533b6b686275a58a648eb
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.
---
.../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,