public static class GridNioServer.Builder<T> extends Object
GridNioServer.| Constructor and Description |
|---|
Builder() |
public GridNioServer<T> build() throws IgniteCheckedException
GridNioServer.IgniteCheckedException - If NIO client worker creation failed or address is already in use.public GridNioServer.Builder<T> readWriteSelectorsAssign(boolean readWriteSelectorsAssign)
readWriteSelectorsAssign - True to assign in/out connections even/odd workers.public GridNioServer.Builder<T> tracing(Tracing tracing)
tracing - Tracing processor.public GridNioServer.Builder<T> address(InetAddress addr)
addr - Local address.public GridNioServer.Builder<T> port(int port)
port - Local port. If -1 passed then server will not be
accepting connections and only outgoing connections will be possible.public GridNioServer.Builder<T> logger(IgniteLogger log)
log - Logger.public GridNioServer.Builder<T> selectorCount(int selectorCnt)
selectorCnt - Selector count.public GridNioServer.Builder<T> igniteInstanceName(@Nullable @Nullable String igniteInstanceName)
igniteInstanceName - Ignite instance name.public GridNioServer.Builder<T> serverName(@Nullable @Nullable String srvName)
srvName - Logical server name for threads identification.public GridNioServer.Builder<T> selectorSpins(long selectorSpins)
selectorSpins - Defines how many non-blocking selector.selectNow() should be made before
falling into selector.select(long) in NIO server. Long value. Default is 0.
Can be set to Long.MAX_VALUE so selector threads will never block.public GridNioServer.Builder<T> tcpNoDelay(boolean tcpNoDelay)
tcpNoDelay - If TCP_NODELAY option should be set to accepted sockets.public GridNioServer.Builder<T> directBuffer(boolean directBuf)
directBuf - Whether to use direct buffer.public GridNioServer.Builder<T> byteOrder(ByteOrder byteOrder)
byteOrder - Byte order to use.public GridNioServer.Builder<T> listener(GridNioServerListener<T> lsnr)
lsnr - NIO server listener.public GridNioServer.Builder<T> socketSendBufferSize(int sockSndBufSize)
sockSndBufSize - Socket send buffer size.public GridNioServer.Builder<T> socketReceiveBufferSize(int sockRcvBufSize)
sockRcvBufSize - Socket receive buffer size.public GridNioServer.Builder<T> sendQueueLimit(int sndQueueLimit)
sndQueueLimit - Send queue limit.public GridNioServer.Builder<T> directMode(boolean directMode)
directMode - Whether direct mode is used.public GridNioServer.Builder<T> filters(GridNioFilter... filters)
filters - NIO filters.public GridNioServer.Builder<T> idleTimeout(long idleTimeout)
idleTimeout - Idle timeout.public GridNioServer.Builder<T> writeTimeout(long writeTimeout)
writeTimeout - Write timeout.public GridNioServer.Builder<T> daemon(boolean daemon)
daemon - Daemon flag to create threads.public GridNioServer.Builder<T> writerFactory(GridNioMessageWriterFactory writerFactory)
writerFactory - Writer factory.public GridNioServer.Builder<T> skipRecoveryPredicate(IgnitePredicate<Message> skipRecoveryPred)
skipRecoveryPred - Skip recovery predicate.public GridNioServer.Builder<T> messageQueueSizeListener(IgniteBiInClosure<GridNioSession,Integer> msgQueueLsnr)
msgQueueLsnr - Message queue size listener.public GridNioServer.Builder<T> workerListener(GridWorkerListener workerLsnr)
workerLsnr - Worker lifecycle listener.public GridNioServer.Builder<T> metricRegistry(MetricRegistry mreg)
mreg - Metrics registry.
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021