Package org.apache.hc.core5.testing.nio
Class H2TestClient
- java.lang.Object
-
- org.apache.hc.core5.testing.nio.IOReactorExecutor<DefaultConnectingIOReactor>
-
- org.apache.hc.core5.testing.nio.AsyncRequester
-
- org.apache.hc.core5.testing.nio.H2TestClient
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,ConnectionInitiator
public class H2TestClient extends AsyncRequester
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.hc.core5.testing.nio.IOReactorExecutor
IOReactorExecutor.Status
-
-
Field Summary
Fields Modifier and Type Field Description private RequestHandlerRegistry<Supplier<AsyncPushConsumer>>
registry
private javax.net.ssl.SSLContext
sslContext
private SSLSessionInitializer
sslSessionInitializer
private SSLSessionVerifier
sslSessionVerifier
-
Constructor Summary
Constructors Constructor Description H2TestClient()
H2TestClient(IOReactorConfig ioReactorConfig, javax.net.ssl.SSLContext sslContext, SSLSessionInitializer sslSessionInitializer, SSLSessionVerifier sslSessionVerifier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.util.concurrent.Future<ClientSessionEndpoint>
connect(java.lang.String hostname, int port, Timeout timeout)
java.util.concurrent.Future<ClientSessionEndpoint>
connect(HttpHost host, Timeout timeout)
java.util.concurrent.Future<ClientSessionEndpoint>
connect(HttpHost host, Timeout timeout, FutureCallback<ClientSessionEndpoint> callback)
void
register(java.lang.String uriPattern, Supplier<AsyncPushConsumer> supplier)
void
start()
void
start(Http1Config http1Config)
void
start(HttpProcessor httpProcessor, Http1Config http1Config)
void
start(HttpProcessor httpProcessor, H2Config h2Config)
void
start(H2Config h2Config)
void
start(IOEventHandlerFactory handlerFactory)
-
Methods inherited from class org.apache.hc.core5.testing.nio.AsyncRequester
connect, createIOReactor, requestSession
-
Methods inherited from class org.apache.hc.core5.testing.nio.IOReactorExecutor
awaitShutdown, close, execute, getStatus, initiateShutdown, reactor, shutdown
-
-
-
-
Field Detail
-
sslContext
private final javax.net.ssl.SSLContext sslContext
-
sslSessionInitializer
private final SSLSessionInitializer sslSessionInitializer
-
sslSessionVerifier
private final SSLSessionVerifier sslSessionVerifier
-
registry
private final RequestHandlerRegistry<Supplier<AsyncPushConsumer>> registry
-
-
Constructor Detail
-
H2TestClient
public H2TestClient(IOReactorConfig ioReactorConfig, javax.net.ssl.SSLContext sslContext, SSLSessionInitializer sslSessionInitializer, SSLSessionVerifier sslSessionVerifier) throws java.io.IOException
- Throws:
java.io.IOException
-
H2TestClient
public H2TestClient() throws java.io.IOException
- Throws:
java.io.IOException
-
-
Method Detail
-
register
public void register(java.lang.String uriPattern, Supplier<AsyncPushConsumer> supplier)
-
start
public void start(IOEventHandlerFactory handlerFactory) throws java.io.IOException
- Throws:
java.io.IOException
-
start
public void start(HttpProcessor httpProcessor, H2Config h2Config) throws java.io.IOException
- Throws:
java.io.IOException
-
start
public void start(HttpProcessor httpProcessor, Http1Config http1Config) throws java.io.IOException
- Throws:
java.io.IOException
-
start
public void start(H2Config h2Config) throws java.io.IOException
- Throws:
java.io.IOException
-
start
public void start(Http1Config http1Config) throws java.io.IOException
- Throws:
java.io.IOException
-
start
public void start() throws java.lang.Exception
- Throws:
java.lang.Exception
-
connect
public java.util.concurrent.Future<ClientSessionEndpoint> connect(HttpHost host, Timeout timeout, FutureCallback<ClientSessionEndpoint> callback)
-
connect
public java.util.concurrent.Future<ClientSessionEndpoint> connect(HttpHost host, Timeout timeout)
-
connect
public java.util.concurrent.Future<ClientSessionEndpoint> connect(java.lang.String hostname, int port, Timeout timeout)
-
-