reactor.netty.transport

Class TransportConnector

java.lang.Object

reactor.netty.transport.TransportConnector

public final class TransportConnector
extends Object

TransportConnector is a helper class that creates, initializes and registers the channel. It performs the actual connect operation to the remote peer or binds the channel.

Since:

1.0.0

Author:

Stephane Maldini, Violeta Georgieva

Method Summary

Modifier and Type	Method and Description
static Mono<Channel>	bind(TransportConfig config, ChannelInitializer<Channel> channelInitializer, SocketAddress bindAddress, boolean isDomainSocket) Binds a Channel.
static Mono<Channel>	connect(TransportConfig config, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup, ChannelInitializer<Channel> channelInitializer) Connect a Channel to the remote peer.

Methods inherited from class java.lang.Object

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

Method Detail

bind

public static Mono<Channel> bind(TransportConfig config,
                                 ChannelInitializer<Channel> channelInitializer,
                                 SocketAddress bindAddress,
                                 boolean isDomainSocket)

Binds a Channel.

Parameters:

config - the transport configuration

channelInitializer - the ChannelInitializer that will be used for initializing the channel pipeline

bindAddress - the local address

Returns:

a Mono of Channel

connect

public static Mono<Channel> connect(TransportConfig config,
                                    SocketAddress remoteAddress,
                                    AddressResolverGroup<?> resolverGroup,
                                    ChannelInitializer<Channel> channelInitializer)

Connect a Channel to the remote peer.

Parameters:

config - the transport configuration

remoteAddress - the SocketAddress to connect to

resolverGroup - the resolver which will resolve the address of the unresolved named address

channelInitializer - the ChannelInitializer that will be used for initializing the channel pipeline

Returns:

a Mono of Channel