35 import javax.net.ssl.SSLSocket;

    35 import javax.net.ssl.SSLSocket;

    36 import java.io.BufferedOutputStream;

    36 import java.io.BufferedOutputStream;

    37 import java.io.IOException;

    37 import java.io.IOException;

    38 import java.io.InputStream;

    38 import java.io.InputStream;

    39 import java.io.OutputStream;

    39 import java.io.OutputStream;

    40 import java.net.Socket;

    41 import java.net.Socket;

    41 import java.nio.ByteBuffer;

    42 import java.nio.ByteBuffer;

    42 import java.util.List;

    43 import java.util.List;

    43 import java.util.concurrent.BlockingQueue;

    44 import java.util.concurrent.BlockingQueue;

    44 import java.util.concurrent.CountDownLatch;

    45 import java.util.concurrent.CountDownLatch;

    81 

    82 

    82         SSLLoopbackSubscriber(SSLContext ctx,

    83         SSLLoopbackSubscriber(SSLContext ctx,

    83                               ExecutorService exec,

    84                               ExecutorService exec,

    84                               CountDownLatch allBytesReceived) throws IOException {

    85                               CountDownLatch allBytesReceived) throws IOException {

    85             SSLServerSocketFactory fac = ctx.getServerSocketFactory();

    86             SSLServerSocketFactory fac = ctx.getServerSocketFactory();

    87             SSLParameters params = serv.getSSLParameters();

    90             SSLParameters params = serv.getSSLParameters();

    88             params.setApplicationProtocols(new String[]{"proto2"});

    91             params.setApplicationProtocols(new String[]{"proto2"});

    89             serv.setSSLParameters(params);

    92             serv.setSSLParameters(params);

    90 

    93 

    91 

    94