public class H2MultiplexingRequester extends AsyncRequester
Constructor and Description |
---|
H2MultiplexingRequester(IOReactorConfig ioReactorConfig,
IOEventHandlerFactory eventHandlerFactory,
Decorator<IOSession> ioSessionDecorator,
Callback<Exception> exceptionCallback,
IOSessionListener sessionListener,
Resolver<HttpHost,InetSocketAddress> addressResolver,
TlsStrategy tlsStrategy)
Use
H2MultiplexingRequesterBootstrap to create instances of this class. |
awaitShutdown, close, close, defaultTarget, getStatus, initiateShutdown, requestSession, start
@Internal public H2MultiplexingRequester(IOReactorConfig ioReactorConfig, IOEventHandlerFactory eventHandlerFactory, Decorator<IOSession> ioSessionDecorator, Callback<Exception> exceptionCallback, IOSessionListener sessionListener, Resolver<HttpHost,InetSocketAddress> addressResolver, TlsStrategy tlsStrategy)
H2MultiplexingRequesterBootstrap
to create instances of this class.public void closeIdle(TimeValue idleTime)
public TimeValue getValidateAfterInactivity()
public void setValidateAfterInactivity(TimeValue timeValue)
public Cancellable execute(HttpHost target, AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context)
public Cancellable execute(AsyncClientExchangeHandler exchangeHandler, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context)
public Cancellable execute(HttpHost target, AsyncClientExchangeHandler exchangeHandler, Timeout timeout, HttpContext context)
public Cancellable execute(AsyncClientExchangeHandler exchangeHandler, Timeout timeout, HttpContext context)
public final <T> Future<T> execute(HttpHost target, AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context, FutureCallback<T> callback)
public final <T> Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, HandlerFactory<AsyncPushConsumer> pushHandlerFactory, Timeout timeout, HttpContext context, FutureCallback<T> callback)
public final <T> Future<T> execute(HttpHost target, AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, HttpContext context, FutureCallback<T> callback)
public final <T> Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, HttpContext context, FutureCallback<T> callback)
public final <T> Future<T> execute(AsyncRequestProducer requestProducer, AsyncResponseConsumer<T> responseConsumer, Timeout timeout, FutureCallback<T> callback)
@Internal public H2ConnPool getConnPool()
public final Future<IOSession> connect(NamedEndpoint arg0, SocketAddress arg1, SocketAddress arg2, Timeout arg3, Object arg4, FutureCallback<IOSession> arg5)
connect
in interface ConnectionInitiator
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.