Repository: cxf
Updated Branches:
  refs/heads/master be99c5301 -> 1f7241ba6


[CXF-6778] reset cached destination without using excception listener as it is 
not always available


Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/1f7241ba
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/1f7241ba
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/1f7241ba

Branch: refs/heads/master
Commit: 1f7241ba6017f1496e9b8aadec5c807ed05e63b4
Parents: be99c53
Author: Christian Schneider <ch...@die-schneider.net>
Authored: Wed Apr 19 16:41:27 2017 +0200
Committer: Christian Schneider <ch...@die-schneider.net>
Committed: Wed Apr 19 21:32:49 2017 +0200

----------------------------------------------------------------------
 .../main/java/org/apache/cxf/transport/jms/JMSConduit.java   | 1 +
 .../main/java/org/apache/cxf/transport/jms/JMSFactory.java   | 8 --------
 2 files changed, 1 insertion(+), 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/1f7241ba/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConduit.java
----------------------------------------------------------------------
diff --git 
a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConduit.java 
b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConduit.java
index 1c432e3..2654353 100644
--- 
a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConduit.java
+++ 
b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSConduit.java
@@ -148,6 +148,7 @@ public class JMSConduit extends AbstractConduit implements 
JMSExchangeSender, Me
             // Close connection so it will be refreshed on next try
             ResourceCloser.close(connection);
             this.connection = null;
+            jmsConfig.resetCachedReplyDestination();
             this.staticReplyDestination = null;
             if (this.jmsListener != null) {
                 this.jmsListener.shutdown();

http://git-wip-us.apache.org/repos/asf/cxf/blob/1f7241ba/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSFactory.java
----------------------------------------------------------------------
diff --git 
a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSFactory.java 
b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSFactory.java
index e8ebc29..26fea0d 100644
--- 
a/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSFactory.java
+++ 
b/rt/transports/jms/src/main/java/org/apache/cxf/transport/jms/JMSFactory.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
 
 import javax.jms.Connection;
 import javax.jms.ConnectionFactory;
-import javax.jms.ExceptionListener;
 import javax.jms.JMSException;
 
 import org.apache.cxf.Bus;
@@ -87,13 +86,6 @@ public final class JMSFactory {
         if (jmsConfig.getDurableSubscriptionClientId() != null) {
             connection.setClientID(jmsConfig.getDurableSubscriptionClientId());
         }
-        connection.setExceptionListener(new ExceptionListener() {
-            
-            @Override
-            public void onException(JMSException exception) {
-                jmsConfig.resetCachedReplyDestination();
-            }
-        });
         return connection;
     }
 

Reply via email to