public class Http1TestClient extends AsyncRequester
Constructor and Description |
---|
Http1TestClient() |
Http1TestClient(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 |
shutdown(TimeValue graceTime) |
void |
start() |
void |
start(Http1Config http1Config) |
void |
start(HttpProcessor httpProcessor,
Http1Config http1Config) |
connect, requestSession
public Http1TestClient(IOReactorConfig ioReactorConfig, SSLContext sslContext, SSLSessionInitializer sslSessionInitializer, SSLSessionVerifier sslSessionVerifier) throws IOException
IOException
public Http1TestClient() throws IOException
IOException
public void start(HttpProcessor httpProcessor, Http1Config http1Config) throws IOException
IOException
public void start(Http1Config http1Config) throws IOException
IOException
public void start() throws IOException
IOException
public 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
IOException
public IOReactorStatus getStatus()
public void awaitShutdown(TimeValue waitTime) throws InterruptedException
InterruptedException
public void initiateShutdown()
public void shutdown(TimeValue graceTime)
public void close() throws Exception
close
in interface AutoCloseable
Exception
Copyright © 2005–2022 The Apache Software Foundation. All rights reserved.