Apache HttpComponents Core HTTP/1.1 5.2.4 · org.apache.hc.core5.http.impl.bootstrap.AsyncRequester

Modifier and Type	Field and Description
private final Resolver<HttpHost, InetSocketAddress>	addressResolver
private final DefaultConnectingIOReactor	ioReactor

Access	Constructor and Description
public	AsyncRequester(final IOEventHandlerFactory eventHandlerFactory, final IOReactorConfig ioReactorConfig, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final Callback<IOSession> sessionShutdownCallback, final Resolver<HttpHost, InetSocketAddress> addressResolver)

Method Summary

Modifier and Type	Method and Description
public void	awaitShutdown(final TimeValue wait time. waitTime) Implements org.apache.hc.core5.reactor.IOReactor.awaitShutdown. Blocks for the given period of time in milliseconds awaiting the completion of the reactor shutdown.
public void	close(final CloseMode How to close the receiver. closeMode) Implements org.apache.hc.core5.reactor.IOReactor.close. Shuts down the I/O reactor either gracefully or immediately.
public void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
pack-priv ConnectionInitiator	getIOReactor() Implements abstract org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase.getIOReactor.
public IOReactorStatus	getStatus() Implements org.apache.hc.core5.reactor.IOReactor.getStatus. Returns the current status of the reactor.
public void	initiateShutdown() Implements org.apache.hc.core5.reactor.IOReactor.initiateShutdown. Initiates shutdown of the reactor without blocking.
public Future<IOSession>	requestSession(final HttpHost host, final Timeout timeout, final Object attachment, final FutureCallback<IOSession> callback)
public void	start() Implements org.apache.hc.core5.reactor.IOReactorService.start. Starts I/O reactor.

Inherited from org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase:: connect

addressResolver	back to summary
private final Resolver<HttpHost, InetSocketAddress> addressResolver

ioReactor	back to summary
private final DefaultConnectingIOReactor ioReactor

AsyncRequester	back to summary
public AsyncRequester(final IOEventHandlerFactory eventHandlerFactory, final IOReactorConfig ioReactorConfig, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final Callback<IOSession> sessionShutdownCallback, final Resolver<HttpHost, InetSocketAddress> addressResolver) Annotations @Internal

Method Detail

awaitShutdown	back to summary
public void awaitShutdown(final TimeValue waitTime) throws InterruptedException Implements org.apache.hc.core5.reactor.IOReactor.awaitShutdown. Doc from org.apache.hc.core5.reactor.IOReactor.awaitShutdown. Blocks for the given period of time in milliseconds awaiting the completion of the reactor shutdown. Parameters waitTime:TimeValue wait time. Annotations @Override

awaitShutdown

back to summary

public void awaitShutdown(final TimeValue waitTime) throws InterruptedException

Implements org.apache.hc.core5.reactor.IOReactor.awaitShutdown.

Doc from org.apache.hc.core5.reactor.IOReactor.awaitShutdown.

Blocks for the given period of time in milliseconds awaiting the completion of the reactor shutdown.

Parameters

waitTime:TimeValue: wait time.

Annotations

@Override

close	back to summary
public void close(final CloseMode closeMode) Implements org.apache.hc.core5.reactor.IOReactor.close. Doc from org.apache.hc.core5.reactor.IOReactor.close. Shuts down the I/O reactor either gracefully or immediately. During graceful shutdown individual I/O sessions should be informed about imminent termination and be given a grace period to complete the ongoing I/O sessions. During immediate shutdown all ongoing I/O sessions get aborted immediately. Parameters closeMode:CloseMode Doc from org.apache.hc.core5.io.ModalCloseable.close. How to close the receiver. Annotations @Override

back to summary

public void close(final CloseMode closeMode)

Implements org.apache.hc.core5.reactor.IOReactor.close.

Doc from org.apache.hc.core5.reactor.IOReactor.close.

Shuts down the I/O reactor either gracefully or immediately. During graceful shutdown individual I/O sessions should be informed about imminent termination and be given a grace period to complete the ongoing I/O sessions. During immediate shutdown all ongoing I/O sessions get aborted immediately.

Parameters

closeMode:CloseMode

Doc from org.apache.hc.core5.io.ModalCloseable.close.

How to close the receiver.

Annotations

@Override

close back to summary

close	back to summary
public void close() throws IOException Implements java.io.Closeable.close. Doc from java.io.Closeable.close. Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. As noted in `AutoCloseable#close()`, cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the `Closeable` as closed, prior to throwing the `IOException`. Annotations @Override Exceptions IOException: if an I/O error occurs

public void close() throws IOException

Implements java.io.Closeable.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs

getIOReactor	back to summary
pack-priv ConnectionInitiator getIOReactor() Implements abstract org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase.getIOReactor. Annotations @Override

getIOReactor

back to summary

pack-priv ConnectionInitiator getIOReactor()

Implements abstract org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase.getIOReactor.

Annotations

@Override

getStatus	back to summary
public IOReactorStatus getStatus() Implements org.apache.hc.core5.reactor.IOReactor.getStatus. Doc from org.apache.hc.core5.reactor.IOReactor.getStatus. Returns the current status of the reactor. Returns:IOReactorStatus reactor status. Annotations @Override

getStatus

back to summary

public IOReactorStatus getStatus()

Implements org.apache.hc.core5.reactor.IOReactor.getStatus.

Doc from org.apache.hc.core5.reactor.IOReactor.getStatus.

Returns the current status of the reactor.

Returns:IOReactorStatus

reactor status.

Annotations

@Override

initiateShutdown	back to summary
public void initiateShutdown() Implements org.apache.hc.core5.reactor.IOReactor.initiateShutdown. Doc from org.apache.hc.core5.reactor.IOReactor.initiateShutdown. Initiates shutdown of the reactor without blocking. The reactor is expected to terminate all active connections, to shut down itself and to release system resources it currently holds Annotations @Override

initiateShutdown

back to summary

public void initiateShutdown()

Implements org.apache.hc.core5.reactor.IOReactor.initiateShutdown.

Doc from org.apache.hc.core5.reactor.IOReactor.initiateShutdown.

Initiates shutdown of the reactor without blocking. The reactor is expected to terminate all active connections, to shut down itself and to release system resources it currently holds

Annotations

@Override

requestSession	back to summary
public Future<IOSession> requestSession(final HttpHost host, final Timeout timeout, final Object attachment, final FutureCallback<IOSession> callback)

start	back to summary
public void start() Implements org.apache.hc.core5.reactor.IOReactorService.start. Doc from org.apache.hc.core5.reactor.IOReactorService.start. Starts I/O reactor. Annotations @Override

start

back to summary

public void start()

Implements org.apache.hc.core5.reactor.IOReactorService.start.

Doc from org.apache.hc.core5.reactor.IOReactorService.start.

Starts I/O reactor.

Annotations

@Override

public Class AsyncRequester

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail