diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/network/io/NonBlockingSenderReceiver.java | 5 |
1 files changed, 4 insertions, 1 deletions
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<ByteBuffer> 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<ByteBuffer> _sslEngine.setWantClientAuth(true); } _netInputBuffer = ByteBuffer.allocate(_sslEngine.getSession().getPacketBufferSize()); - onTransportEncryptionAction.run(); } try |