reactor.netty.tcp

Class TcpClientConfig

java.lang.Object

reactor.netty.transport.TransportConfig

reactor.netty.transport.ClientTransportConfig<TcpClientConfig>

reactor.netty.tcp.TcpClientConfig

public final class TcpClientConfig
extends ClientTransportConfig<TcpClientConfig>

Encapsulate all necessary configuration for TCP client transport. The public API is read-only.

Since:

1.0.0

Author:

Violeta Georgieva

Method Summary

Modifier and Type	Method and Description
int	channelHash()
ChannelOperations.OnSetup	channelOperationsProvider() Return the associated ChannelOperations.OnSetup, config implementations might override this.
protected AddressResolverGroup<?>	defaultAddressResolverGroup() Provides a global AddressResolverGroup from TcpResources that is shared amongst all TCP clients.
protected LoggingHandler	defaultLoggingHandler() Return the default LoggingHandler to wiretap this transport.
protected LoopResources	defaultLoopResources() Return the default LoopResources for this transport.
protected ChannelMetricsRecorder	defaultMetricsRecorder() Return the configured metrics recorder.
protected ChannelPipelineConfigurer	defaultOnChannelInit() Return the default callback if any or ChannelPipelineConfigurer.emptyConfigurer().
boolean	isSecure() Return true if that TcpClient secured via SSL transport.
SslProvider	sslProvider() Return the current SslProvider if that TcpClient secured via SSL transport or null.

Methods inherited from class reactor.netty.transport.ClientTransportConfig

channelType, connectionProvider, defaultConnectionObserver, doOnConnect, doOnConnected, doOnDisconnected, eventLoopGroup, getNameResolverProvider, hasProxy, proxyProvider, proxyProvider, proxyProviderSupplier, proxyProviderSupplier, remoteAddress, resolver, resolverInternal

Methods inherited from class reactor.netty.transport.TransportConfig

attributes, bindAddress, channelGroup, channelInitializer, connectionFactory, connectionObserver, doOnChannelInit, isPreferNative, loggingHandler, loggingHandler, loopResources, metricsRecorder, metricsRecorder, metricsRecorderInternal, options, updateMap

Methods inherited from class java.lang.Object

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

Method Detail

channelHash

public int channelHash()

Overrides:

channelHash in class ClientTransportConfig<TcpClientConfig>

channelOperationsProvider

public ChannelOperations.OnSetup channelOperationsProvider()

Description copied from class: TransportConfig

Return the associated ChannelOperations.OnSetup, config implementations might override this.

Overrides:

channelOperationsProvider in class TransportConfig

Returns:

the associated ChannelOperations.OnSetup

isSecure

public final boolean isSecure()

Return true if that TcpClient secured via SSL transport.

Returns:

true if that TcpClient secured via SSL transport

sslProvider

@Nullable
public SslProvider sslProvider()

Return the current SslProvider if that TcpClient secured via SSL transport or null.

Returns:

the current SslProvider if that TcpClient secured via SSL transport or null

defaultAddressResolverGroup

protected AddressResolverGroup<?> defaultAddressResolverGroup()

Provides a global AddressResolverGroup from TcpResources that is shared amongst all TCP clients. AddressResolverGroup uses the global LoopResources from TcpResources.

Specified by:

defaultAddressResolverGroup in class ClientTransportConfig<TcpClientConfig>

Returns:

the global AddressResolverGroup

defaultLoggingHandler

protected LoggingHandler defaultLoggingHandler()

Description copied from class: TransportConfig

Return the default LoggingHandler to wiretap this transport.

Specified by:

defaultLoggingHandler in class TransportConfig

Returns:

the default LoggingHandler to wiretap this transport

defaultLoopResources

protected LoopResources defaultLoopResources()

Description copied from class: TransportConfig

Return the default LoopResources for this transport.

Specified by:

defaultLoopResources in class TransportConfig

Returns:

the default LoopResources for this transport

defaultMetricsRecorder

protected ChannelMetricsRecorder defaultMetricsRecorder()

Description copied from class: TransportConfig

Return the configured metrics recorder.

Specified by:

defaultMetricsRecorder in class TransportConfig

Returns:

the configured metrics recorder

defaultOnChannelInit

protected ChannelPipelineConfigurer defaultOnChannelInit()

Description copied from class: TransportConfig

Return the default callback if any or ChannelPipelineConfigurer.emptyConfigurer().

Overrides:

defaultOnChannelInit in class ClientTransportConfig<TcpClientConfig>

Returns:

the default callback if any or ChannelPipelineConfigurer.emptyConfigurer()