public class H2TestClient extends AsyncRequester
| Constructor and Description |
|---|
H2TestClient() |
H2TestClient(IOReactorConfig ioReactorConfig,
SSLContext sslContext,
SSLSessionInitializer sslSessionInitializer,
SSLSessionVerifier sslSessionVerifier) |
| Modifier and Type | Method and Description |
|---|---|
void |
awaitShutdown(TimeValue waitTime) |
void |
close() |
Future<ClientSessionEndpoint> |
connect(HttpHost host,
Timeout timeout) |
Future<ClientSessionEndpoint> |
connect(HttpHost host,
Timeout timeout,
FutureCallback<ClientSessionEndpoint> callback) |
Future<ClientSessionEndpoint> |
connect(String hostname,
int port,
Timeout timeout) |
protected void |
execute(IOEventHandlerFactory ioEventHandlerFactory) |
IOReactorStatus |
getStatus() |
void |
initiateShutdown() |
void |
register(String uriPattern,
Supplier<AsyncPushConsumer> supplier) |
void |
shutdown(TimeValue graceTime) |
void |
start() |
void |
start(H2Config h2Config) |
void |
start(Http1Config http1Config) |
void |
start(HttpProcessor httpProcessor,
H2Config h2Config) |
void |
start(HttpProcessor httpProcessor,
Http1Config http1Config) |
void |
start(IOEventHandlerFactory handlerFactory) |
connect, requestSessionpublic H2TestClient(IOReactorConfig ioReactorConfig, SSLContext sslContext, SSLSessionInitializer sslSessionInitializer, SSLSessionVerifier sslSessionVerifier) throws IOException
IOExceptionpublic H2TestClient()
throws IOException
IOExceptionpublic void register(String uriPattern, Supplier<AsyncPushConsumer> supplier)
public void start(IOEventHandlerFactory handlerFactory) throws IOException
IOExceptionpublic void start(HttpProcessor httpProcessor, H2Config h2Config) throws IOException
IOExceptionpublic void start(HttpProcessor httpProcessor, Http1Config http1Config) throws IOException
IOExceptionpublic void start(H2Config h2Config) throws IOException
IOExceptionpublic void start(Http1Config http1Config) throws IOException
IOExceptionpublic Future<ClientSessionEndpoint> connect(HttpHost host, Timeout timeout, FutureCallback<ClientSessionEndpoint> callback)
public Future<ClientSessionEndpoint> connect(HttpHost host, Timeout timeout)
public Future<ClientSessionEndpoint> connect(String hostname, int port, Timeout timeout)
protected void execute(IOEventHandlerFactory ioEventHandlerFactory) throws IOException
IOExceptionpublic IOReactorStatus getStatus()
public void awaitShutdown(TimeValue waitTime) throws InterruptedException
InterruptedExceptionpublic void initiateShutdown()
public void shutdown(TimeValue graceTime)
public void close()
throws Exception
close in interface AutoCloseableExceptionCopyright © 2005–2021 The Apache Software Foundation. All rights reserved.