Package 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	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 Mono<Channel>	connect(TransportConfig config, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup, ChannelInitializer<Channel> channelInitializer, EventLoop eventLoop)	Connect a Channel to the remote peer.
static Mono<Channel>	connect(TransportConfig config, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup, ChannelInitializer<Channel> channelInitializer, EventLoop eventLoop, ContextView contextView)	Connect a Channel to the remote peer.
static Mono<Channel>	connect(TransportConfig config, SocketAddress remoteAddress, AddressResolverGroup<?> resolverGroup, ChannelInitializer<Channel> channelInitializer, ContextView contextView)	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 Details

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

isDomainSocket - true if DomainSocketChannel or ServerDomainSocketChannel is needed, false otherwise

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

connect

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

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

contextView - the current ContextView

Returns:

a Mono of Channel

Since:

1.0.26

connect

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

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

eventLoop - the EventLoop to use for handling the channel.

Returns:

a Mono of Channel

connect

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

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

eventLoop - the EventLoop to use for handling the channel.

contextView - the current ContextView

Returns:

a Mono of Channel

Since:

1.0.26