public final class ReactorNetty
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ACCESS_LOG_ENABLED
Specifies whether the Http Server access log will be enabled.
|
static java.lang.String |
IO_SELECT_COUNT
Default selector thread count, fallback to -1 (no selector thread)
|
static java.lang.String |
IO_WORKER_COUNT
Default worker thread count, fallback to available processor
(but with a minimum value of 4)
|
static java.lang.String |
NATIVE
Default value whether the native transport (epoll, kqueue) will be preferred,
fallback it will be preferred when available
|
static java.lang.String |
POOL_ACQUIRE_TIMEOUT
Default acquisition timeout (milliseconds) before error.
|
static java.lang.String |
POOL_GET_PERMITS_SAMPLING_RATE
Default
getPermitsSamplingRate (between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy . |
static java.lang.String |
POOL_LEASING_STRATEGY
Default leasing strategy (fifo, lifo), fallback to fifo.
|
static java.lang.String |
POOL_MAX_CONNECTIONS
Default max connections.
|
static java.lang.String |
POOL_MAX_IDLE_TIME
Default max idle time, fallback - max idle time is not specified.
|
static java.lang.String |
POOL_MAX_LIFE_TIME
Default max life time, fallback - max life time is not specified.
|
static java.lang.String |
POOL_RETURN_PERMITS_SAMPLING_RATE
Default
returnPermitsSamplingRate (between 0d and 1d (percentage))
to be used with a SamplingAllocationStrategy . |
static java.util.function.Predicate<io.netty.buffer.ByteBuf> |
PREDICATE_GROUP_FLUSH |
static java.lang.String |
SHUTDOWN_QUIET_PERIOD
Default quiet period that guarantees that the disposal of the underlying LoopResources
will not happen, fallback to 2 seconds.
|
static java.lang.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 java.lang.String |
SSL_CLIENT_DEBUG
Default value whether the SSL debugging on the client side will be enabled/disabled,
fallback to SSL debugging disabled
|
static java.lang.String |
SSL_HANDSHAKE_TIMEOUT
Default SSL handshake timeout (milliseconds), fallback to 10 seconds
|
static java.lang.String |
SSL_SERVER_DEBUG
Default value whether the SSL debugging on the server side will be enabled/disabled,
fallback to SSL debugging disabled
|
static java.lang.String |
UDP_IO_THREAD_COUNT
Default worker thread count for UDP, fallback to available processor
(but with a minimum value of 4)
|
static java.time.ZoneId |
ZONE_ID_SYSTEM
Specifies the zone id used by the access log
|
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
format(io.netty.channel.Channel channel,
java.lang.String msg)
Append channel ID to a log message for correlated traces
|
static void |
safeRelease(java.lang.Object msg)
Try to call
ReferenceCounted.release() if the specified message implements ReferenceCounted . |
static java.lang.String |
toPrettyHexDump(java.lang.Object msg)
Pretty hex dump will be returned when the object is
ByteBuf or ByteBufHolder |
static java.lang.RuntimeException |
wrapException(java.lang.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 java.lang.String IO_WORKER_COUNT
public static final java.lang.String IO_SELECT_COUNT
public static final java.lang.String UDP_IO_THREAD_COUNT
public static final java.lang.String SHUTDOWN_QUIET_PERIOD
public static final java.lang.String SHUTDOWN_TIMEOUT
public static final java.lang.String NATIVE
public static final java.lang.String POOL_MAX_CONNECTIONS
public static final java.lang.String POOL_ACQUIRE_TIMEOUT
public static final java.lang.String POOL_MAX_IDLE_TIME
public static final java.lang.String POOL_MAX_LIFE_TIME
public static final java.lang.String POOL_LEASING_STRATEGY
public static final java.lang.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 java.lang.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 java.lang.String SSL_HANDSHAKE_TIMEOUT
public static final java.lang.String SSL_CLIENT_DEBUG
public static final java.lang.String SSL_SERVER_DEBUG
public static final java.lang.String ACCESS_LOG_ENABLED
public static final java.time.ZoneId ZONE_ID_SYSTEM
public static final java.util.function.Predicate<io.netty.buffer.ByteBuf> PREDICATE_GROUP_FLUSH
public static void safeRelease(java.lang.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 java.lang.String format(io.netty.channel.Channel channel, java.lang.String msg)
channel
- current channel associated with the msgmsg
- the log msgpublic static java.lang.String toPrettyHexDump(java.lang.Object msg)
ByteBuf
or ByteBufHolder
public static java.lang.RuntimeException wrapException(java.lang.Throwable throwable)
RuntimeException