cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cschnei...@apache.org
Subject cxf git commit: [CXF-6778] Use exceptionlistener optionally to react faster if supported
Date Thu, 20 Apr 2017 14:07:45 GMT
Repository: cxf
Updated Branches:
  refs/heads/master 1f9cbe367 -> a98345918


[CXF-6778] Use exceptionlistener optionally to react faster if supported


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

Branch: refs/heads/master
Commit: a98345918f30b8288621ff7b3e7dc09947e86527
Parents: 1f9cbe3
Author: Christian Schneider <chris@die-schneider.net>
Authored: Thu Apr 20 16:07:38 2017 +0200
Committer: Christian Schneider <chris@die-schneider.net>
Committed: Thu Apr 20 16:07:38 2017 +0200

----------------------------------------------------------------------
 .../apache/cxf/transport/jms/JMSConduit.java    | 22 ++++++++++++++++++++
 1 file changed, 22 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/a9834591/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 2654353..e588542 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
@@ -32,6 +32,7 @@ import java.util.logging.Logger;
 
 import javax.jms.Connection;
 import javax.jms.Destination;
+import javax.jms.ExceptionListener;
 import javax.jms.JMSException;
 import javax.jms.MessageListener;
 import javax.jms.Session;
@@ -107,6 +108,7 @@ public class JMSConduit extends AbstractConduit implements JMSExchangeSender,
Me
                 result = connection;
                 if (result == null) {
                     result = JMSFactory.createConnection(jmsConfig);
+                    trySetExListener(result);
                     result.start();
                     connection = result;
                 }
@@ -116,6 +118,26 @@ public class JMSConduit extends AbstractConduit implements JMSExchangeSender,
Me
     }
 
     /**
+     * Register exception listener to react faster when a connection is reset.  
+     * 
+     * @param conn
+     */
+    private void trySetExListener(Connection conn) {
+        try {
+            conn.setExceptionListener(new ExceptionListener() {
+                
+                @Override
+                public void onException(JMSException exception) {
+                    jmsConfig.resetCachedReplyDestination();
+                    staticReplyDestination = null;
+                }
+            });
+        } catch (JMSException e) {
+            // setException is not supported on all providers  
+        }
+    }
+
+    /**
      * Send the JMS message and if the MEP is not oneway receive the response.
      *
      * @param exchange the Exchange containing the outgoing message


Mime
View raw message