Top Description Fields Constructors Methods
org.apache.hc.core5.http2.impl.nio.bootstrap

public Class H2MultiplexingRequester

extends AsyncRequester
Class Inheritance
Imports
java.io.IOException, java.net.InetSocketAddress, java.nio.ByteBuffer, java.util.List, .Set, java.util.concurrent.Future, org.apache.hc.core5.annotation.Internal, org.apache.hc.core5.concurrent.Cancellable, .CancellableDependency, .ComplexFuture, .FutureCallback, .FutureContribution, org.apache.hc.core5.function.Callback, .Decorator, .Resolver, org.apache.hc.core5.http.ConnectionClosedException, .EntityDetails, .Header, .HttpException, .HttpHost, .HttpResponse, .ProtocolException, org.apache.hc.core5.http.impl.DefaultAddressResolver, org.apache.hc.core5.http.impl.bootstrap.AsyncRequester, org.apache.hc.core5.http.nio.AsyncClientExchangeHandler, .AsyncPushConsumer, .AsyncRequestProducer, .AsyncResponseConsumer, .CapacityChannel, .DataStreamChannel, .HandlerFactory, .RequestChannel, org.apache.hc.core5.http.nio.command.RequestExecutionCommand, .ShutdownCommand, org.apache.hc.core5.http.nio.ssl.TlsStrategy, org.apache.hc.core5.http.nio.support.BasicClientExchangeHandler, org.apache.hc.core5.http.protocol.HttpContext, .HttpCoreContext, org.apache.hc.core5.http2.nio.pool.H2ConnPool, org.apache.hc.core5.net.URIAuthority, org.apache.hc.core5.reactor.Command, .IOEventHandlerFactory, .IOReactorConfig, .IOSession, .IOSessionListener, org.apache.hc.core5.util.Args, .TimeValue, .Timeout
HTTP/2 multiplexing client side message exchange initiator.
Since
5.0

Field Summary

Modifier and TypeField and Description
private final H2ConnPool
connPool

Constructor Summary

AccessConstructor and Description
public
H2MultiplexingRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final Resolver<HttpHost, InetSocketAddress> addressResolver, final TlsStrategy tlsStrategy)

Use H2MultiplexingRequesterBootstrap to create instances of this class.

Method Summary

Modifier and TypeMethod and Description
public void
closeIdle(final TimeValue idleTime)

public Cancellable
execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext context)

public Cancellable
execute(final AsyncClientExchangeHandler exchangeHandler, final Timeout timeout, final HttpContext context)

private void
execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final CancellableDependency cancellableDependency, final Timeout timeout, final HttpContext context)

public final <T> Future<T>
execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)

public final <T> Future<T>
execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)

public final <T> Future<T>
execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final FutureCallback<T> callback)

public H2ConnPool
getConnPool()

public Set<HttpHost>
getRoutes()

public TimeValue
getValidateAfterInactivity()

public void
setValidateAfterInactivity(final TimeValue timeValue)

Inherited from org.apache.hc.core5.http.impl.bootstrap.AsyncRequester:
awaitShutdowncloseclosegetStatusinitiateShutdownrequestSessionstart

Field Detail

connPoolback to summary
private final H2ConnPool connPool

Constructor Detail

H2MultiplexingRequesterback to summary
public H2MultiplexingRequester(final IOReactorConfig ioReactorConfig, final IOEventHandlerFactory eventHandlerFactory, final Decorator<IOSession> ioSessionDecorator, final Callback<Exception> exceptionCallback, final IOSessionListener sessionListener, final Resolver<HttpHost, InetSocketAddress> addressResolver, final TlsStrategy tlsStrategy)

Use H2MultiplexingRequesterBootstrap to create instances of this class.

Annotations
@Internal

Method Detail

closeIdleback to summary
public void closeIdle(final TimeValue idleTime)
executeback to summary
public Cancellable execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext context)
executeback to summary
public Cancellable execute(final AsyncClientExchangeHandler exchangeHandler, final Timeout timeout, final HttpContext context)
executeback to summary
private void execute(final AsyncClientExchangeHandler exchangeHandler, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final CancellableDependency cancellableDependency, final Timeout timeout, final HttpContext context)
executeback to summary
public final <T> Future<T> execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final HandlerFactory<AsyncPushConsumer> pushHandlerFactory, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)
executeback to summary
public final <T> Future<T> execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final HttpContext context, final FutureCallback<T> callback)
executeback to summary
public final <T> Future<T> execute(final AsyncRequestProducer requestProducer, final AsyncResponseConsumer<T> responseConsumer, final Timeout timeout, final FutureCallback<T> callback)
getConnPoolback to summary
public H2ConnPool getConnPool()
Annotations
@Internal
getRoutesback to summary
public Set<HttpHost> getRoutes()
getValidateAfterInactivityback to summary
public TimeValue getValidateAfterInactivity()
setValidateAfterInactivityback to summary
public void setValidateAfterInactivity(final TimeValue timeValue)