[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.

[coheigea]

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 <cohei...@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,