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:

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 final RequestHandlerRegistry<Supplier<AsyncPushConsumer>>	registry
private final SSLContext	sslContext
private final SSLSessionInitializer	sslSessionInitializer
private final SSLSessionVerifier	sslSessionVerifier

Constructor Summary

Constructors

Constructor	Description
H2TestClient()
H2TestClient(IOReactorConfig ioReactorConfig, SSLContext sslContext, SSLSessionInitializer sslSessionInitializer, SSLSessionVerifier sslSessionVerifier)

Method Summary

Modifier and Type	Method	Description
Future<ClientSessionEndpoint>	connect(String hostname, int port, Timeout timeout)
Future<ClientSessionEndpoint>	connect(HttpHost host, Timeout timeout)
Future<ClientSessionEndpoint>	connect(HttpHost host, Timeout timeout, FutureCallback<ClientSessionEndpoint> callback)
void	register(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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

sslContext

private final SSLContext sslContext

sslSessionInitializer

private final SSLSessionInitializer sslSessionInitializer

sslSessionVerifier

private final SSLSessionVerifier sslSessionVerifier

registry

private final RequestHandlerRegistry<Supplier<AsyncPushConsumer>> registry

Constructor Details

H2TestClient

public H2TestClient(IOReactorConfig ioReactorConfig,
 SSLContext sslContext,
 SSLSessionInitializer sslSessionInitializer,
 SSLSessionVerifier sslSessionVerifier)
             throws IOException

Throws:

IOException

H2TestClient

public H2TestClient()
             throws IOException

Throws:

IOException

Method Details

register

public void register(String uriPattern,
 Supplier<AsyncPushConsumer> supplier)

start

public void start(IOEventHandlerFactory handlerFactory)
           throws IOException

Throws:

IOException

start

public void start(HttpProcessor httpProcessor,
 H2Config h2Config)
           throws IOException

Throws:

IOException

start

public void start(HttpProcessor httpProcessor,
 Http1Config http1Config)
           throws IOException

Throws:

IOException

start

public void start(H2Config h2Config)
           throws IOException

Throws:

IOException

start

public void start(Http1Config http1Config)
           throws IOException

Throws:

IOException

start

public void start()
           throws Exception

Throws:

Exception

connect

public Future<ClientSessionEndpoint> connect(HttpHost host,
 Timeout timeout,
 FutureCallback<ClientSessionEndpoint> callback)

connect

public Future<ClientSessionEndpoint> connect(HttpHost host,
 Timeout timeout)

connect

public Future<ClientSessionEndpoint> connect(String hostname,
 int port,
 Timeout timeout)