Top Description Fields Constructors Methods
io.vertx.core.http.impl

public Class HttpChannelConnector

extends Object
Class Inheritance
Imports
io.netty.channel.Channel, .ChannelHandler, .ChannelPipeline, io.netty.handler.codec.http.HttpClientCodec, .HttpContentDecompressor, io.netty.handler.logging.LoggingHandler, io.netty.handler.ssl.SslHandler, io.netty.handler.timeout.IdleStateHandler, io.vertx.core.AsyncResult, .Future, .Handler, .Promise, io.vertx.core.http.HttpClientOptions, .HttpHeaders, .HttpVersion, io.vertx.core.impl.ContextInternal, io.vertx.core.impl.future.PromiseInternal, io.vertx.core.net.NetSocket, .ProxyOptions, .SocketAddress, io.vertx.core.net.impl.NetClientImpl, .NetSocketImpl, .VertxHandler, io.vertx.core.spi.metrics.ClientMetrics, .HttpClientMetrics, java.util.ArrayList, .List, .Map
Performs the channel configuration and connection according to the client options and the protocol version.
Author
Julien Viet

Field Summary

Modifier and TypeField and Description
private final HttpClientBase
client

private final ClientMetrics<M, T, Req, Resp>
metrics

private final NetClientImpl
netClient

private final HttpClientOptions
options

private final SocketAddress
peerAddress

private final ProxyOptions
proxyOptions

private final SocketAddress
server

private final boolean
ssl

private final boolean
useAlpn

private final HttpVersion
version

Constructor Summary

AccessConstructor and Description
public
HttpChannelConnector(HttpClientBase client, NetClientImpl netClient, ProxyOptions proxyOptions, ClientMetrics<M, T, Req, Resp> metrics, HttpVersion version, boolean ssl, boolean useAlpn, SocketAddress peerAddress, SocketAddress server)

Method Summary

Modifier and TypeMethod and Description
private void
applyHttp1xConnectionOptions(ChannelPipeline pipeline)

private void
applyHttp2ConnectionOptions(ChannelPipeline pipeline)

private void
connect(ContextInternal context, Promise<NetSocket> promise)

private void
connectFailed(Channel ch, Throwable t, Promise<HttpClientConnection> future)

private void
http1xConnected(HttpVersion version, SocketAddress server, boolean ssl, ContextInternal context, Object socketMetric, Channel ch, Promise<HttpClientConnection> future)

private void
http2Connected(ContextInternal context, Object metric, Channel ch, PromiseInternal<HttpClientConnection> promise)

public void
httpConnect(ContextInternal context, Handler<AsyncResult<HttpClientConnection>> handler)

public SocketAddress
server()

public Future<HttpClientConnection>
wrap(ContextInternal context, NetSocket so_)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

clientback to summary
private final HttpClientBase client
metricsback to summary
private final ClientMetrics<M, T, Req, Resp> metrics
netClientback to summary
private final NetClientImpl netClient
optionsback to summary
private final HttpClientOptions options
peerAddressback to summary
private final SocketAddress peerAddress
proxyOptionsback to summary
private final ProxyOptions proxyOptions
serverback to summary
private final SocketAddress server
sslback to summary
private final boolean ssl
useAlpnback to summary
private final boolean useAlpn
versionback to summary
private final HttpVersion version

Constructor Detail

HttpChannelConnectorback to summary
public HttpChannelConnector(HttpClientBase client, NetClientImpl netClient, ProxyOptions proxyOptions, ClientMetrics<M, T, Req, Resp> metrics, HttpVersion version, boolean ssl, boolean useAlpn, SocketAddress peerAddress, SocketAddress server)

Method Detail

applyHttp1xConnectionOptionsback to summary
private void applyHttp1xConnectionOptions(ChannelPipeline pipeline)
applyHttp2ConnectionOptionsback to summary
private void applyHttp2ConnectionOptions(ChannelPipeline pipeline)
connectback to summary
private void connect(ContextInternal context, Promise<NetSocket> promise)
connectFailedback to summary
private void connectFailed(Channel ch, Throwable t, Promise<HttpClientConnection> future)
http1xConnectedback to summary
private void http1xConnected(HttpVersion version, SocketAddress server, boolean ssl, ContextInternal context, Object socketMetric, Channel ch, Promise<HttpClientConnection> future)
http2Connectedback to summary
private void http2Connected(ContextInternal context, Object metric, Channel ch, PromiseInternal<HttpClientConnection> promise)
httpConnectback to summary
public void httpConnect(ContextInternal context, Handler<AsyncResult<HttpClientConnection>> handler)
serverback to summary
public SocketAddress server()
wrapback to summary
public Future<HttpClientConnection> wrap(ContextInternal context, NetSocket so_)