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 <[email protected]> Authored: Wed Apr 19 16:41:27 2017 +0200 Committer: Christian Schneider <[email protected]> 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; }
