diff options
author | Robert Gemmell <robbie@apache.org> | 2011-08-15 14:46:06 +0000 |
---|---|---|
committer | Robert Gemmell <robbie@apache.org> | 2011-08-15 14:46:06 +0000 |
commit | 67663fcc5f0d01f1df1a8cc006ec86725031f10a (patch) | |
tree | 8a18a7ec88a9b99ab6269af27465820769db26ed /java/common/src/test | |
parent | 034f02dac2f4645094633c77805b1e538e4d0583 (diff) | |
download | qpid-python-67663fcc5f0d01f1df1a8cc006ec86725031f10a.tar.gz |
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
Diffstat (limited to 'java/common/src/test')
-rw-r--r-- | java/common/src/test/java/org/apache/qpid/transport/network/io/IoTransport.java | 6 |
1 files changed, 4 insertions, 2 deletions
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<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); |