io.vertx.core.net.impl

Class ChannelProvider

java.lang.Object

io.vertx.core.net.impl.ChannelProvider

public final class ChannelProvider
extends Object

The logic for connecting to an host, this implementations performs a connection to the host after resolving its internet address. See if we can replace that by a Netty handler sometimes.

Author:

Julien Viet

Constructor Summary

Constructors

Constructor and Description
ChannelProvider(io.netty.bootstrap.Bootstrap bootstrap, SSLHelper sslHelper, ContextInternal context)

Method Summary

Modifier and Type	Method and Description
String	applicationProtocol()
io.netty.util.concurrent.Future<io.netty.channel.Channel>	connect(SocketAddress remoteAddress, SocketAddress peerAddress, String serverName, boolean ssl)
ChannelProvider	handler(Handler<io.netty.channel.Channel> handler) Set a handler called when the channel has been established.
ChannelProvider	proxyOptions(ProxyOptions proxyOptions) Set the proxy options to use.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ChannelProvider

public ChannelProvider(io.netty.bootstrap.Bootstrap bootstrap,
                       SSLHelper sslHelper,
                       ContextInternal context)

Method Detail

proxyOptions

public ChannelProvider proxyOptions(ProxyOptions proxyOptions)

Set the proxy options to use.

Parameters:

proxyOptions - the proxy options to use

Returns:

fluently this

handler

public ChannelProvider handler(Handler<io.netty.channel.Channel> handler)

Set a handler called when the channel has been established.

Parameters:

handler - the channel handler

Returns:

fluently this

applicationProtocol

public String applicationProtocol()

Returns:

the application protocol resulting from the ALPN negotiation

connect

public io.netty.util.concurrent.Future<io.netty.channel.Channel> connect(SocketAddress remoteAddress,
                                                                         SocketAddress peerAddress,
                                                                         String serverName,
                                                                         boolean ssl)