summaryrefslogtreecommitdiff
path: root/qpid/java/common/src
diff options
context:
space:
mode:
authorRobert Godfrey <rgodfrey@apache.org>2014-08-08 12:30:03 +0000
committerRobert Godfrey <rgodfrey@apache.org>2014-08-08 12:30:03 +0000
commite7375322dc1083dbfffe49a903d4737a6943907e (patch)
tree8eda764527588da967dc27ba180b0b3353eea335 /qpid/java/common/src
parentbf0089dd71fc9b173f7d8670439672394d73f847 (diff)
downloadqpid-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.java13
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));
}
}