diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-08-08 12:30:03 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-08-08 12:30:03 +0000 |
| commit | e7375322dc1083dbfffe49a903d4737a6943907e (patch) | |
| tree | 8eda764527588da967dc27ba180b0b3353eea335 /qpid/java/common/src | |
| parent | bf0089dd71fc9b173f7d8670439672394d73f847 (diff) | |
| download | qpid-python-e7375322dc1083dbfffe49a903d4737a6943907e.tar.gz | |
QPID-5978 : [Java Client] fail faster when a TCP connection is established, but the AMQP layer is not - e.g. due to SSL negotiation failure
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616736 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java | 13 |
1 files changed, 7 insertions, 6 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java index 13a16d07b5..1bbf166d82 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/security/ssl/SSLReceiver.java @@ -20,17 +20,18 @@ */ package org.apache.qpid.transport.network.security.ssl; -import org.apache.qpid.transport.Receiver; -import org.apache.qpid.transport.TransportException; -import org.apache.qpid.transport.network.security.SSLStatus; -import org.apache.qpid.transport.util.Logger; +import java.nio.ByteBuffer; import javax.net.ssl.SSLEngine; import javax.net.ssl.SSLEngineResult; import javax.net.ssl.SSLEngineResult.HandshakeStatus; import javax.net.ssl.SSLEngineResult.Status; import javax.net.ssl.SSLException; -import java.nio.ByteBuffer; + +import org.apache.qpid.transport.Receiver; +import org.apache.qpid.transport.TransportException; +import org.apache.qpid.transport.network.security.SSLStatus; +import org.apache.qpid.transport.util.Logger; public class SSLReceiver implements Receiver<ByteBuffer> { @@ -192,7 +193,7 @@ public class SSLReceiver implements Receiver<ByteBuffer> { _sslStatus.getSslLock().notifyAll(); } - exception(new TransportException("Error in SSLReceiver",e)); + exception(new TransportException("Error in SSLReceiver: " + e.getMessage(),e)); } } |
