QPID-3342: Regression when forming SSL connections.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1157866 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 4 insertions, 2 deletions

diff --git a/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java b/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java
index 796a845593..773d7bc117 100644
--- a/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java
+++ b/qpid/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java
@@ -29,6 +29,7 @@ import org.apache.qpid.ssl.SSLContextFactory;
 import org.apache.qpid.transport.Binding;
 import org.apache.qpid.transport.Sender;
 import org.apache.qpid.transport.TransportException;
+import org.apache.qpid.transport.network.security.SSLStatus;
 import org.apache.qpid.transport.network.security.ssl.SSLReceiver;
 import org.apache.qpid.transport.network.security.ssl.SSLSender;
 import org.apache.qpid.transport.util.Logger;
@@ -119,9 +120,10 @@ public final class IoTransport<E>
         }
         IoSender ios = new IoSender(socket, 2*writeBufferSize, timeout);
         ios.initiate();
-        this.sender = new SSLSender(engine,ios);
+        final SSLStatus sslStatus = new SSLStatus();
+        this.sender = new SSLSender(engine,ios, sslStatus);
         this.endpoint = binding.endpoint(sender);
-        this.receiver = new IoReceiver(socket, new SSLReceiver(engine,binding.receiver(endpoint),(SSLSender)sender),
+        this.receiver = new IoReceiver(socket, new SSLReceiver(engine,binding.receiver(endpoint),sslStatus),
                 2*readBufferSize, timeout);
         this.receiver.initiate();
         ios.registerCloseListener(this.receiver);