From 66c5a217c9891e1dfee14eeb093866373293f265 Mon Sep 17 00:00:00 2001 From: Keith Wall Date: Thu, 11 Dec 2014 14:06:44 +0000 Subject: Only when a port is running TLS only can it be identified early as encrypted (those running both PLAIN/TLS have to wait for the sniff) git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/QPID-6262-JavaBrokerNIO@1644644 13f79535-47bb-0310-9956-ffa450edef68 --- .../apache/qpid/transport/network/io/NonBlockingSenderReceiver.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'qpid/java') diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java index 1f6d50e68f..c056fc0015 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java @@ -99,6 +99,10 @@ public class NonBlockingSenderReceiver implements Runnable, Sender if(encryptionSet.size() == 1) { _transportEncryption = _encryptionSet.iterator().next(); + if (_transportEncryption == TransportEncryption.TLS) + { + onTransportEncryptionAction.run(); + } } if(encryptionSet.contains(TransportEncryption.TLS)) @@ -115,7 +119,6 @@ public class NonBlockingSenderReceiver implements Runnable, Sender _sslEngine.setWantClientAuth(true); } _netInputBuffer = ByteBuffer.allocate(_sslEngine.getSession().getPacketBufferSize()); - onTransportEncryptionAction.run(); } try -- cgit v1.2.1