public static class IOReactorConfig.Builder extends Object
| Modifier and Type | Method and Description | 
|---|---|
| IOReactorConfig | build() | 
| static int | getDefaultMaxIOThreadCount()Gets the default value for  ioThreadCount. | 
| IOReactorConfig.Builder | setBacklogSize(int backlogSize)Sets the default backlog size value for server sockets binds. | 
| static void | setDefaultMaxIOThreadCount(int defaultMaxIOThreadCount)Sets the default value for  ioThreadCount. | 
| IOReactorConfig.Builder | setIoThreadCount(int ioThreadCount)Sets the number of I/O dispatch threads to be used by the I/O reactor. | 
| IOReactorConfig.Builder | setRcvBufSize(int rcvBufSize)Sets the default value of the  SocketOptions.SO_RCVBUFparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setSelectInterval(TimeValue selectInterval)Sets time interval at which the I/O reactor wakes up to check for timed out sessions
 and session requests. | 
| IOReactorConfig.Builder | setSndBufSize(int sndBufSize)Sets the default value of the  SocketOptions.SO_SNDBUFparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setSocksProxyAddress(SocketAddress socksProxyAddress)Sets the address of the SOCKS proxy to use. | 
| IOReactorConfig.Builder | setSocksProxyPassword(String socksProxyPassword)Sets the password to provide to the SOCKS proxy for username/password authentication. | 
| IOReactorConfig.Builder | setSocksProxyUsername(String socksProxyUsername)Sets the username to provide to the SOCKS proxy for username/password authentication. | 
| IOReactorConfig.Builder | setSoKeepAlive(boolean soKeepAlive)Sets the default value of the  SocketOptions.SO_KEEPALIVEparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setSoLinger(int soLinger,
           TimeUnit timeUnit)Sets the default value of the  SocketOptions.SO_LINGERparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setSoLinger(TimeValue soLinger)Sets the default value of the  SocketOptions.SO_LINGERparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setSoReuseAddress(boolean soReuseAddress)Sets the default value of the  SocketOptions.SO_REUSEADDRparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setSoTimeout(int soTimeout,
            TimeUnit timeUnit)Sets the default socket timeout value for non-blocking I/O operations. | 
| IOReactorConfig.Builder | setSoTimeout(Timeout soTimeout)Sets the default socket timeout value for non-blocking I/O operations. | 
| IOReactorConfig.Builder | setTcpKeepCount(int tcpKeepCount)Sets the maximum number of keepalive probes TCP should send before dropping the connection. | 
| IOReactorConfig.Builder | setTcpKeepIdle(int tcpKeepIdle)Sets the time (in seconds) the connection needs to remain idle before TCP starts
 sending keepalive probes. | 
| IOReactorConfig.Builder | setTcpKeepInterval(int tcpKeepInterval)Sets the time (in seconds) between individual keepalive probes. | 
| IOReactorConfig.Builder | setTcpNoDelay(boolean tcpNoDelay)Sets the default value of the  SocketOptions.TCP_NODELAYparameter
 for newly created sockets. | 
| IOReactorConfig.Builder | setTrafficClass(int trafficClass)Sets the default value of the  SocketOptions.IP_TOSparameter
 for newly created sockets. | 
public static int getDefaultMaxIOThreadCount()
ioThreadCount. Returns
 Runtime.availableProcessors() if
 setDefaultMaxIOThreadCount(int) was called with a value less <= 0.public static void setDefaultMaxIOThreadCount(int defaultMaxIOThreadCount)
ioThreadCount. Use a value <= 0 to
 cause getDefaultMaxIOThreadCount() to return
 Runtime.availableProcessors().defaultMaxIOThreadCount - the default value for ioThreadCount.public IOReactorConfig.Builder setSelectInterval(TimeValue selectInterval)
 Default: 1000 milliseconds.
 
public IOReactorConfig.Builder setIoThreadCount(int ioThreadCount)
 Default: 2
 
public IOReactorConfig.Builder setSoTimeout(int soTimeout, TimeUnit timeUnit)
 Default: 0 (no timeout)
 
SocketOptions.SO_TIMEOUTpublic IOReactorConfig.Builder setSoTimeout(Timeout soTimeout)
 Default: 0 (no timeout)
 
SocketOptions.SO_TIMEOUTpublic IOReactorConfig.Builder setSoReuseAddress(boolean soReuseAddress)
SocketOptions.SO_REUSEADDR parameter
 for newly created sockets.
 
 Default: false
 
SocketOptions.SO_REUSEADDRpublic IOReactorConfig.Builder setSoLinger(int soLinger, TimeUnit timeUnit)
SocketOptions.SO_LINGER parameter
 for newly created sockets.
 
 Default: -1
 
SocketOptions.SO_LINGERpublic IOReactorConfig.Builder setSoLinger(TimeValue soLinger)
SocketOptions.SO_LINGER parameter
 for newly created sockets.
 
 Default: -1
 
SocketOptions.SO_LINGERpublic IOReactorConfig.Builder setSoKeepAlive(boolean soKeepAlive)
SocketOptions.SO_KEEPALIVE parameter
 for newly created sockets.
 
 Default: -1
 
SocketOptions.SO_KEEPALIVEpublic IOReactorConfig.Builder setTcpNoDelay(boolean tcpNoDelay)
SocketOptions.TCP_NODELAY parameter
 for newly created sockets.
 
 Default: false
 
SocketOptions.TCP_NODELAYpublic IOReactorConfig.Builder setTrafficClass(int trafficClass)
SocketOptions.IP_TOS parameter
 for newly created sockets.
 
 Default: 0
 
SocketOptions.IP_TOSpublic IOReactorConfig.Builder setSndBufSize(int sndBufSize)
SocketOptions.SO_SNDBUF parameter
 for newly created sockets.
 
 Default: 0 (system default)
 
SocketOptions.SO_SNDBUFpublic IOReactorConfig.Builder setRcvBufSize(int rcvBufSize)
SocketOptions.SO_RCVBUF parameter
 for newly created sockets.
 
 Default: 0 (system default)
 
SocketOptions.SO_RCVBUFpublic IOReactorConfig.Builder setBacklogSize(int backlogSize)
 Default: 0 (system default)
 
public IOReactorConfig.Builder setTcpKeepIdle(int tcpKeepIdle)
public IOReactorConfig.Builder setTcpKeepInterval(int tcpKeepInterval)
public IOReactorConfig.Builder setTcpKeepCount(int tcpKeepCount)
public IOReactorConfig.Builder setSocksProxyAddress(SocketAddress socksProxyAddress)
public IOReactorConfig.Builder setSocksProxyUsername(String socksProxyUsername)
public IOReactorConfig.Builder setSocksProxyPassword(String socksProxyPassword)
public IOReactorConfig build()
Copyright © 2005–2021 The Apache Software Foundation. All rights reserved.