You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by cs...@apache.org on 2017/04/20 07:26:36 UTC
cxf git commit: [CXF-6778] reset cached destination without using
excception listener as it is not always available
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;
}