public final class ReactorNetty extends Object
Modifier and Type | Field and Description |
---|---|
static String |
ACCESS_LOG_ENABLED
Specifies whether the Http Server access log will be enabled.
|
static String |
IO_SELECT_COUNT
Default selector thread count, fallback to -1 (no selector thread)
|
static String |
IO_WORKER_COUNT
Default worker thread count, fallback to available processor
(but with a minimum value of 4)
|
static String |
NATIVE
Default value whether the native transport (epoll, kqueue) will be preferred,
fallback it will be preferred when available
|
static String |
POOL_ACQUIRE_TIMEOUT
Default acquisition timeout (milliseconds) before error.
|
static String |
POOL_GET_PERMITS_SAMPLING_RATE
Default
getPermitsSamplingRate (between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy . |
static String |
POOL_LEASING_STRATEGY
Default leasing strategy (fifo, lifo), fallback to fifo.
|
static String |
POOL_MAX_CONNECTIONS
Default max connections.
|
static String |
POOL_MAX_IDLE_TIME
Default max idle time, fallback - max idle time is not specified.
|
static String |
POOL_MAX_LIFE_TIME
Default max life time, fallback - max life time is not specified.
|
static String |
POOL_RETURN_PERMITS_SAMPLING_RATE
Default
returnPermitsSamplingRate (between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy . |
static Predicate<ByteBuf> |
PREDICATE_GROUP_FLUSH |
static String |
SHUTDOWN_QUIET_PERIOD
Default quiet period that guarantees that the disposal of the underlying LoopResources
will not happen, fallback to 2 seconds.
|
static String |
SHUTDOWN_TIMEOUT
Default maximum amount of time to wait until the disposal of the underlying LoopResources
regardless if a task was submitted during the quiet period, fallback to 15 seconds.
|
static String |
SSL_CLIENT_DEBUG
Default value whether the SSL debugging on the client side will be enabled/disabled,
fallback to SSL debugging disabled
|
static String |
SSL_HANDSHAKE_TIMEOUT
Default SSL handshake timeout (milliseconds), fallback to 10 seconds
|
static String |
SSL_SERVER_DEBUG
Default value whether the SSL debugging on the server side will be enabled/disabled,
fallback to SSL debugging disabled
|
static String |
UDP_IO_THREAD_COUNT
Default worker thread count for UDP, fallback to available processor
(but with a minimum value of 4)
|
static ZoneId |
ZONE_ID_SYSTEM
Specifies the zone id used by the access log
|
Modifier and Type | Method and Description |
---|---|
static String |
format(Channel channel,
String msg)
Append channel ID to a log message for correlated traces
|
static ContextView |
getChannelContext(Channel channel)
Returns
ContextView from the channel attributes when exists otherwise returns null . |
static void |
safeRelease(Object msg)
Try to call
ReferenceCounted.release() if the specified message implements ReferenceCounted . |
static void |
setChannelContext(Channel channel,
ContextView contextView)
Adds
ContextView to the channel attributes. |
static String |
toPrettyHexDump(Object msg)
Pretty hex dump will be returned when the object is
ByteBuf or ByteBufHolder |
static RuntimeException |
wrapException(Throwable throwable)
Wrap possibly fatal or singleton exception into a new exception instance in order to propagate in reactor flows without side effect.
|
public static final String IO_WORKER_COUNT
public static final String IO_SELECT_COUNT
Note: In most use cases using a worker thread also as a selector thread works well. A possible use case for specifying a separate selector thread might be when the worker threads are too busy and connections cannot be accepted fast enough.
Note: Although more than 1 can be configured as a selector thread count, in reality only 1 thread will be used as a selector thread.
public static final String UDP_IO_THREAD_COUNT
public static final String SHUTDOWN_QUIET_PERIOD
public static final String SHUTDOWN_TIMEOUT
public static final String NATIVE
public static final String POOL_MAX_CONNECTIONS
public static final String POOL_ACQUIRE_TIMEOUT
public static final String POOL_MAX_IDLE_TIME
Note: This configuration is not applicable for TcpClient
.
A TCP connection is always closed and never returned to the pool.
public static final String POOL_MAX_LIFE_TIME
Note: This configuration is not applicable for TcpClient
.
A TCP connection is always closed and never returned to the pool.
public static final String POOL_LEASING_STRATEGY
Note: This configuration is not applicable for TcpClient
.
A TCP connection is always closed and never returned to the pool.
public static final String POOL_GET_PERMITS_SAMPLING_RATE
getPermitsSamplingRate
(between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy
.
This strategy wraps a sizeBetween
AllocationStrategy
and samples calls to AllocationStrategy.getPermits(int)
.
Fallback - sampling is not enabled.public static final String POOL_RETURN_PERMITS_SAMPLING_RATE
returnPermitsSamplingRate
(between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy
.
This strategy wraps a sizeBetween
AllocationStrategy
and samples calls to AllocationStrategy.returnPermits(int)
.
Fallback - sampling is not enabled.public static final String SSL_HANDSHAKE_TIMEOUT
public static final String SSL_CLIENT_DEBUG
public static final String SSL_SERVER_DEBUG
public static final String ACCESS_LOG_ENABLED
public static final ZoneId ZONE_ID_SYSTEM
public static void safeRelease(Object msg)
ReferenceCounted.release()
if the specified message implements ReferenceCounted
.
If the specified message doesn't implement ReferenceCounted
or it is already released,
this method does nothing.public static String format(Channel channel, String msg)
channel
- current channel associated with the msgmsg
- the log msgpublic static String toPrettyHexDump(Object msg)
ByteBuf
or ByteBufHolder
@Nullable public static ContextView getChannelContext(Channel channel)
ContextView
from the channel attributes when exists otherwise returns null
.channel
- the channelContextView
from the channel attributes when exists otherwise returns null
public static void setChannelContext(Channel channel, @Nullable ContextView contextView)
ContextView
to the channel attributes. When null
is provided, the channel
attribute's value will be deleted.channel
- the channelcontextView
- ContextView
that will be added to the channel attributespublic static RuntimeException wrapException(Throwable throwable)
RuntimeException