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 java.util.function.Function<Bootstrap,java.util.function.BiConsumer<ConnectionObserver,Channel>>	findMetricsSupport(Bootstrap b) Find metrics support in the given client bootstrap
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	removeMetricsSupport(Bootstrap b)
static ServerBootstrap	removeMetricsSupport(ServerBootstrap b)
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 ServerBootstrap	updateLogSupport(ServerBootstrap b, LoggingHandler handler) Configure log support for a ServerBootstrap
static Bootstrap	updateMetricsSupport(Bootstrap b, ChannelMetricsRecorder recorder)
static Bootstrap	updateMetricsSupport(Bootstrap b, String name, String protocol)
static ServerBootstrap	updateMetricsSupport(ServerBootstrap b, ChannelMetricsRecorder recorder)
static ServerBootstrap	updateMetricsSupport(ServerBootstrap b, String name, String protocol)

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 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

updateMetricsSupport

public static ServerBootstrap updateMetricsSupport(ServerBootstrap b,
                                                   String name,
                                                   String protocol)

updateMetricsSupport

public static ServerBootstrap updateMetricsSupport(ServerBootstrap b,
                                                   ChannelMetricsRecorder recorder)

updateMetricsSupport

public static Bootstrap updateMetricsSupport(Bootstrap b,
                                             String name,
                                             String protocol)

updateMetricsSupport

public static Bootstrap updateMetricsSupport(Bootstrap b,
                                             ChannelMetricsRecorder recorder)

removeMetricsSupport

public static ServerBootstrap removeMetricsSupport(ServerBootstrap b)

removeMetricsSupport

public static Bootstrap removeMetricsSupport(Bootstrap b)

findMetricsSupport

@Nullable
public static java.util.function.Function<Bootstrap,java.util.function.BiConsumer<ConnectionObserver,Channel>> findMetricsSupport(Bootstrap b)

Find metrics support in the given client bootstrap

Parameters:

b - a bootstrap to search

Returns:

any BootstrapHandlers.DeferredMetricsSupport found or null