public class AsyncRequester extends Object implements ConnectionInitiator
Constructor and Description |
---|
AsyncRequester(IOReactorConfig ioReactorConfig) |
Modifier and Type | Method and Description |
---|---|
void |
awaitShutdown(TimeValue waitTime) |
void |
close() |
Future<IOSession> |
connect(NamedEndpoint remoteEndpoint,
SocketAddress remoteAddress,
SocketAddress localAddress,
Timeout timeout,
Object attachment,
FutureCallback<IOSession> callback) |
protected void |
execute(IOEventHandlerFactory ioEventHandlerFactory) |
IOReactorStatus |
getStatus() |
void |
initiateShutdown() |
Future<IOSession> |
requestSession(HttpHost host,
Timeout timeout,
FutureCallback<IOSession> callback) |
void |
shutdown(TimeValue graceTime) |
public AsyncRequester(IOReactorConfig ioReactorConfig)
public Future<IOSession> requestSession(HttpHost host, Timeout timeout, FutureCallback<IOSession> callback)
public Future<IOSession> connect(NamedEndpoint remoteEndpoint, SocketAddress remoteAddress, SocketAddress localAddress, Timeout timeout, Object attachment, FutureCallback<IOSession> callback)
connect
in interface ConnectionInitiator
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–2021 The Apache Software Foundation. All rights reserved.