Class H2MultiplexingRequester
- java.lang.Object
-
- org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase
-
- org.apache.hc.core5.http.impl.bootstrap.AsyncRequester
-
- org.apache.hc.core5.http2.impl.nio.bootstrap.H2MultiplexingRequester
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
,ModalCloseable
,ConnectionInitiator
,IOReactor
,IOReactorService
public class H2MultiplexingRequester extends AsyncRequester
HTTP/2 multiplexing client side message exchange initiator.- Since:
- 5.0
-
-
Field Summary
Fields Modifier and Type Field Description private H2ConnPool
connPool
-
Constructor Summary
Constructors Constructor Description H2MultiplexingRequester(IOReactorConfig ioReactorConfig, IOEventHandlerFactory eventHandlerFactory, Decorator<IOSession> ioSessionDecorator, Callback<java.lang.Exception> exceptionCallback, IOSessionListener sessionListener, Resolver<HttpHost,java.net.InetSocketAddress> addressResolver, TlsStrategy tlsStrategy)
UseH2MultiplexingRequesterBootstrap
to create instances of this class.
-
Method Summary
-
Methods inherited from class org.apache.hc.core5.http.impl.bootstrap.AsyncRequester
awaitShutdown, close, close, getStatus, initiateShutdown, requestSession, start
-
Methods inherited from class org.apache.hc.core5.http.impl.bootstrap.AbstractConnectionInitiatorBase
connect
-
-
-
-
Field Detail
-
connPool
private final H2ConnPool connPool
-
-
Constructor Detail
-
H2MultiplexingRequester
@Internal public H2MultiplexingRequester(IOReactorConfig ioReactorConfig, IOEventHandlerFactory eventHandlerFactory, Decorator<IOSession> ioSessionDecorator, Callback<java.lang.Exception> exceptionCallback, IOSessionListener sessionListener, Resolver<HttpHost,java.net.InetSocketAddress> addressResolver, TlsStrategy tlsStrategy)
UseH2MultiplexingRequesterBootstrap
to create instances of this class.
-
-
Method Detail
-
closeIdle
public void closeIdle(TimeValue idleTime)
-
getRoutes
public java.util.Set<HttpHost> getRoutes()
-
getValidateAfterInactivity
public TimeValue getValidateAfterInactivity()
-
setValidateAfterInactivity
public void setValidateAfterInactivity(TimeValue timeValue)
-
execute
public Cancellable execute(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context)
-
execute
public Cancellable execute(AsyncClientExchangeHandler exchangeHandler, Timeout timeout, HttpContext context)
-
execute
private void execute(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, CancellableDependency cancellableDependency, Timeout timeout, HttpContext context)
-
execute
public final <T> java.util.concurrent.Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context, FutureCallback<T> callback)
-
execute
public final <T> java.util.concurrent.Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, HttpContext context, FutureCallback<T> callback)
-
execute
public final <T> java.util.concurrent.Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, FutureCallback<T> callback)
-
getConnPool
@Internal public H2ConnPool getConnPool()
-
-