ReactorNetty (Reactor Netty 0.8.13.RELEASE)

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

All Methods Static Methods Concrete Methods
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 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.

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
  - 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.
  - format
```
public static String format(Channel channel,
                            String msg)
```
    Append channel ID to a log message for correlated traces
    
    Parameters:
    
    channel - current channel associated with the msg
    
    msg - the log msg
    
    Returns:
    
    a formatted msg
  - wrapException
```
public 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.
    
    Returns:
    
    a wrapped RuntimeException

Class ReactorNetty

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

IO_WORKER_COUNT

IO_SELECT_COUNT

UDP_IO_THREAD_COUNT

NATIVE

POOL_MAX_CONNECTIONS

POOL_ACQUIRE_TIMEOUT

SSL_HANDSHAKE_TIMEOUT

SSL_CLIENT_DEBUG

SSL_SERVER_DEBUG

ACCESS_LOG_ENABLED

Method Detail

safeRelease

format

wrapException