From 67663fcc5f0d01f1df1a8cc006ec86725031f10a Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Mon, 15 Aug 2011 14:46:06 +0000 Subject: QPID-3342: Regression when forming SSL connections. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1157866 13f79535-47bb-0310-9956-ffa450edef68 --- .../test/java/org/apache/qpid/transport/network/io/IoTransport.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'java/common/src/test') diff --git a/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java b/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java index 796a845593..773d7bc117 100644 --- a/java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java +++ b/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 } 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); -- cgit v1.2.1