reactor.netty

Class ReactorNetty

java.lang.Object

reactor.netty.ReactorNetty

public final class ReactorNetty
extends Object

Internal helpers for reactor-netty contracts

Author:

Stephane Maldini

Field Summary

Fields

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, if -1 will never wait to acquire before opening a new connection in an unbounded fashion.
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)

Method Summary

Modifier and Type	Method and Description
static String	format(Channel channel, String msg)
static void	safeRelease(Object msg) Try to call ReferenceCounted.release() if the specified message implements ReferenceCounted.

Methods inherited from class java.lang.Object

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

Field Detail

IO_WORKER_COUNT

public static final String IO_WORKER_COUNT

Default worker thread count, fallback to available processor (but with a minimum value of 4)

See Also:

Constant Field Values

IO_SELECT_COUNT

public static final String IO_SELECT_COUNT

Default selector thread count, fallback to -1 (no selector thread)

See Also:

Constant Field Values

UDP_IO_THREAD_COUNT

public static final String UDP_IO_THREAD_COUNT

Default worker thread count for UDP, fallback to available processor (but with a minimum value of 4)

See Also:

Constant Field Values

NATIVE

public static final String NATIVE

Default value whether the native transport (epoll, kqueue) will be preferred, fallback it will be preferred when available

See Also:

Constant Field Values

POOL_MAX_CONNECTIONS

public static final String POOL_MAX_CONNECTIONS

Default max connections, if -1 will never wait to acquire before opening a new connection in an unbounded fashion. Fallback to available number of processors (but with a minimum value of 16)

See Also:

Constant Field Values

POOL_ACQUIRE_TIMEOUT

public static final String POOL_ACQUIRE_TIMEOUT

Default acquisition timeout (milliseconds) before error. If -1 will never wait to acquire before opening a new connection in an unbounded fashion. Fallback 45 seconds

See Also:

Constant Field Values

SSL_HANDSHAKE_TIMEOUT

public static final String SSL_HANDSHAKE_TIMEOUT

Default SSL handshake timeout (milliseconds), fallback to 10 seconds

See Also:

Constant Field Values

SSL_CLIENT_DEBUG

public static final String SSL_CLIENT_DEBUG

Default value whether the SSL debugging on the client side will be enabled/disabled, fallback to SSL debugging disabled

See Also:

Constant Field Values

SSL_SERVER_DEBUG

public static final String SSL_SERVER_DEBUG

Default value whether the SSL debugging on the server side will be enabled/disabled, fallback to SSL debugging disabled

See Also:

Constant Field Values

ACCESS_LOG_ENABLED

public static final String ACCESS_LOG_ENABLED

Specifies whether the Http Server access log will be enabled. By default it is disabled.

See Also:

Constant Field Values

Method Detail

format

public static String format(Channel channel,
                            String msg)

safeRelease

public static void safeRelease(Object msg)

Try to call 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.