reactor.netty.channel

Class BootstrapHandlers

java.lang.Object

reactor.netty.channel.BootstrapHandlers

public abstract class BootstrapHandlers
extends Object

Helper to update configuration the main Bootstrap and ServerBootstrap handlers

Author:

Stephane Maldini

Method Summary

Modifier and Type	Method and Description
static ChannelOperations.OnSetup	channelOperationFactory(AbstractBootstrap<?,?> b) Obtain and remove the current ChannelOperations.OnSetup from the bootstrap.
static void	channelOperationFactory(AbstractBootstrap<?,?> b, ChannelOperations.OnSetup opsFactory) Set a ChannelOperations.OnSetup to the passed bootstrap.
static ConnectionObserver	childConnectionObserver(ServerBootstrap b) Obtain and remove the current childHandler ConnectionObserver from the bootstrap.
static void	childConnectionObserver(ServerBootstrap b, ConnectionObserver connectionObserver) Add a childHandler ConnectionObserver to the passed bootstrap.
static ConnectionObserver	connectionObserver(AbstractBootstrap<?,?> b) Obtain and remove the current ConnectionObserver from the bootstrap.
static void	connectionObserver(AbstractBootstrap<?,?> b, ConnectionObserver connectionObserver) Add a ConnectionObserver to the passed bootstrap.
static void	finalizeHandler(Bootstrap b, ChannelOperations.OnSetup opsFactory, ConnectionObserver listener) Finalize a bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.
static void	finalizeHandler(ServerBootstrap b, ChannelOperations.OnSetup opsFactory, ConnectionObserver childListener) Finalize a server bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.
static <C> C	findConfiguration(Class<C> clazz, ChannelHandler handler) Find the given typed configuration consumer or return null;
static Bootstrap	removeConfiguration(Bootstrap b, String name) Remove a configuration given its unique name from the given Bootstrap
static ServerBootstrap	removeConfiguration(ServerBootstrap b, String name) Remove a configuration given its unique name from the given ServerBootstrap
static Bootstrap	updateConfiguration(Bootstrap b, String name, java.util.function.BiConsumer<ConnectionObserver,? super Channel> c) Add the configuration consumer to this Bootstrap given a unique configuration name.
static Bootstrap	updateConfiguration(Bootstrap b, String name, java.util.function.Function<? super Bootstrap,? extends java.util.function.BiConsumer<ConnectionObserver,? super Channel>> c) Add the configuration consumer to this Bootstrap given a unique configuration name.
static ServerBootstrap	updateConfiguration(ServerBootstrap b, String name, java.util.function.BiConsumer<ConnectionObserver,? super Channel> c) Add the configuration consumer to this ServerBootstrap given a unique configuration name.
static Bootstrap	updateLogSupport(Bootstrap b, LoggingHandler handler) Configure log support for a Bootstrap
static Bootstrap	updateLogSupport(Bootstrap b, String category, LogLevel level) Configure log support for a Bootstrap
static ServerBootstrap	updateLogSupport(ServerBootstrap b, LoggingHandler handler) Configure log support for a ServerBootstrap

Methods inherited from class java.lang.Object

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

Method Detail

finalizeHandler

public static void finalizeHandler(ServerBootstrap b,
                                   ChannelOperations.OnSetup opsFactory,
                                   ConnectionObserver childListener)

Finalize a server bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.

Parameters:

b - a server bootstrap

opsFactory - an operation factory

childListener - a connection observer

finalizeHandler

public static void finalizeHandler(Bootstrap b,
                                   ChannelOperations.OnSetup opsFactory,
                                   ConnectionObserver listener)

Finalize a bootstrap pipeline configuration by turning it into a ChannelInitializer to safely initialize each child channel.

Parameters:

b - a bootstrap

opsFactory - an operation factory

listener - a connection observer

findConfiguration

@Nullable
public static <C> C findConfiguration(Class<C> clazz,
                                                @Nullable
                                                ChannelHandler handler)

Find the given typed configuration consumer or return null;

Type Parameters:

C - configuration consumer type

Parameters:

clazz - the type of configuration to find

handler - optional handler to scan

Returns:

a typed configuration or null

removeConfiguration

public static ServerBootstrap removeConfiguration(ServerBootstrap b,
                                                  String name)

Remove a configuration given its unique name from the given ServerBootstrap

Parameters:

b - a server bootstrap

name - a configuration name

removeConfiguration

public static Bootstrap removeConfiguration(Bootstrap b,
                                            String name)

Remove a configuration given its unique name from the given Bootstrap

Parameters:

b - a bootstrap

name - a configuration name

channelOperationFactory

public static void channelOperationFactory(AbstractBootstrap<?,?> b,
                                           ChannelOperations.OnSetup opsFactory)

Set a ChannelOperations.OnSetup to the passed bootstrap.

Parameters:

b - the bootstrap to scan

opsFactory - a new ChannelOperations.OnSetup factory

channelOperationFactory

public static ChannelOperations.OnSetup channelOperationFactory(AbstractBootstrap<?,?> b)

Obtain and remove the current ChannelOperations.OnSetup from the bootstrap.

Parameters:

b - the bootstrap to scan

Returns:

current ChannelOperations.OnSetup factory or null

connectionObserver

public static void connectionObserver(AbstractBootstrap<?,?> b,
                                      ConnectionObserver connectionObserver)

Add a ConnectionObserver to the passed bootstrap.

Parameters:

b - the bootstrap to scan

connectionObserver - a new ConnectionObserver

connectionObserver

public static ConnectionObserver connectionObserver(AbstractBootstrap<?,?> b)

Obtain and remove the current ConnectionObserver from the bootstrap.

Parameters:

b - the bootstrap to scan

Returns:

current ConnectionObserver or null

childConnectionObserver

public static void childConnectionObserver(ServerBootstrap b,
                                           ConnectionObserver connectionObserver)

Add a childHandler ConnectionObserver to the passed bootstrap.

Parameters:

b - the bootstrap to scan

connectionObserver - a new ConnectionObserver

childConnectionObserver

public static ConnectionObserver childConnectionObserver(ServerBootstrap b)

Obtain and remove the current childHandler ConnectionObserver from the bootstrap.

Parameters:

b - the bootstrap to scan

Returns:

current ConnectionObserver or null

updateConfiguration

public static Bootstrap updateConfiguration(Bootstrap b,
                                            String name,
                                            java.util.function.BiConsumer<ConnectionObserver,? super Channel> c)

Add the configuration consumer to this Bootstrap given a unique configuration name. Configuration will be run on channel init.

Parameters:

b - a bootstrap

name - a configuration name

c - a configuration consumer

Returns:

the mutated bootstrap

updateConfiguration

public static Bootstrap updateConfiguration(Bootstrap b,
                                            String name,
                                            java.util.function.Function<? super Bootstrap,? extends java.util.function.BiConsumer<ConnectionObserver,? super Channel>> c)

Add the configuration consumer to this Bootstrap given a unique configuration name. Configuration will be run on channel init.

Parameters:

b - a bootstrap

name - a configuration name

c - a deferred configuration consumer

Returns:

the mutated bootstrap

updateConfiguration

public static ServerBootstrap updateConfiguration(ServerBootstrap b,
                                                  String name,
                                                  java.util.function.BiConsumer<ConnectionObserver,? super Channel> c)

Add the configuration consumer to this ServerBootstrap given a unique configuration name. Configuration will be run on child channel init.

Parameters:

b - a server bootstrap

name - a configuration name

c - a configuration consumer

Returns:

the mutated bootstrap

updateLogSupport

public static Bootstrap updateLogSupport(Bootstrap b,
                                         LoggingHandler handler)

Configure log support for a Bootstrap

Parameters:

b - the bootstrap to setup

handler - the logging handler to setup

Returns:

a mutated Bootstrap

updateLogSupport

public static Bootstrap updateLogSupport(Bootstrap b,
                                         String category,
                                         LogLevel level)

Configure log support for a Bootstrap

Parameters:

b - the bootstrap to setup

category - the logger category

level - the logger level

Returns:

a mutated Bootstrap

updateLogSupport

public static ServerBootstrap updateLogSupport(ServerBootstrap b,
                                               LoggingHandler handler)

Configure log support for a ServerBootstrap

Parameters:

b - the bootstrap to setup

handler - the logging handler to setup

Returns:

a mutated ServerBootstrap