You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by ff...@apache.org on 2016/09/05 07:13:51 UTC
cxf git commit: [CXF-7038]ensure the JMS Connection get refreshed so
that the jms retry can get a useful Connection
Repository: cxf
Updated Branches:
refs/heads/master 6fcdc7e9e -> 2ca062173
[CXF-7038]ensure the JMS Connection get refreshed so that the jms retry can get a useful Connection
Project: http://git-wip-us.apache.org/repos/asf/cxf/repo
Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/2ca06217
Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/2ca06217
Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/2ca06217
Branch: refs/heads/master
Commit: 2ca06217311edb8bd70d95a03e59703bffa654b0
Parents: 6fcdc7e
Author: Freeman Fang <fr...@gmail.com>
Authored: Mon Sep 5 15:13:34 2016 +0800
Committer: Freeman Fang <fr...@gmail.com>
Committed: Mon Sep 5 15:13:34 2016 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/cxf/transport/jms/JMSConduit.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cxf/blob/2ca06217/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 f656af7..9a0f4be 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
@@ -230,10 +230,10 @@ public class JMSConduit extends AbstractConduit implements JMSExchangeSender, Me
try {
exchange.wait(jmsConfig.getReceiveTimeout());
} catch (InterruptedException e) {
- throw new RuntimeException("Interrupted while correlating", e);
+ throw new JMSException("Interrupted while correlating " + e.getMessage());
}
if (exchange.get(CORRELATED) != Boolean.TRUE) {
- throw new RuntimeException("Timeout receiving message with correlationId "
+ throw new JMSException("Timeout receiving message with correlationId "
+ correlationId);
}