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

Constructor Summary

Constructors

Constructor and Description
TransportConnector()

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.
static void	setAttributes(Channel channel, Map<AttributeKey<?>,?> attrs) Set the channel attributes
static void	setChannelOptions(Channel channel, Map<ChannelOption<?>,?> options, boolean isDomainSocket) Set the channel options

Methods inherited from class java.lang.Object

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

Constructor Detail

TransportConnector

public TransportConnector()

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

setAttributes

public static void setAttributes(Channel channel,
                                 Map<AttributeKey<?>,?> attrs)

Set the channel attributes

Parameters:

channel - the channel

attrs - the attributes

setChannelOptions

public static void setChannelOptions(Channel channel,
                                     Map<ChannelOption<?>,?> options,
                                     boolean isDomainSocket)

Set the channel options

Parameters:

channel - the channel

options - the options