summaryrefslogtreecommitdiff
path: root/java/common/src/test
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2011-08-15 14:46:06 +0000
committerRobert Gemmell <robbie@apache.org>2011-08-15 14:46:06 +0000
commit67663fcc5f0d01f1df1a8cc006ec86725031f10a (patch)
tree8a18a7ec88a9b99ab6269af27465820769db26ed /java/common/src/test
parent034f02dac2f4645094633c77805b1e538e4d0583 (diff)
downloadqpid-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.java6
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);