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_MAX_CONNECTIONS
Default max connections.
|
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)
|
Modifier and Type | Method and Description |
---|---|
static String |
format(Channel channel,
String msg)
Append channel ID to a log message for correlated traces
|
static void |
safeRelease(Object msg)
Try to call
ReferenceCounted.release() if the specified message implements ReferenceCounted . |
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
public static final String UDP_IO_THREAD_COUNT
public static final String NATIVE
public static final String POOL_MAX_CONNECTIONS
public static final String POOL_ACQUIRE_TIMEOUT
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 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
public static RuntimeException wrapException(Throwable throwable)
RuntimeException