Uses of Class
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi

Packages that use TcpCommunicationSpi

Package	Description
org.apache.ignite.spi.communication.tcp	Contains default TCP/IP-based implementation for communication SPI.

Uses of TcpCommunicationSpi in org.apache.ignite.spi.communication.tcp

Methods in org.apache.ignite.spi.communication.tcp that return TcpCommunicationSpi

Modifier and Type	Method and Description
TcpCommunicationSpi	TcpCommunicationSpi.setAckSendThreshold(int ackSndThreshold) Sets number of received messages per connection to node after which acknowledgment message is sent.
TcpCommunicationSpi	TcpCommunicationSpi.setAddressResolver(AddressResolver addrRslvr) Sets address resolver.
TcpCommunicationSpi	TcpCommunicationSpi.setConnectionsPerNode(int maxConnectionsPerNode) Sets number of connections to each remote node. if isUsePairedConnections() is true then number of connections is doubled and half is used for incoming and half for outgoing messages.
TcpCommunicationSpi	TcpCommunicationSpi.setConnectTimeout(long connTimeout) Sets connect timeout used when establishing connection with remote nodes.
TcpCommunicationSpi	TcpCommunicationSpi.setDirectBuffer(boolean directBuf) Sets flag to allocate direct or heap buffer in SPI.
TcpCommunicationSpi	TcpCommunicationSpi.setDirectSendBuffer(boolean directSndBuf) Sets whether to use direct buffer for sending.
TcpCommunicationSpi	TcpCommunicationSpi.setFilterReachableAddresses(boolean filterReachableAddresses) Setting this option to true enables filter for reachable addresses on creating tcp client.
TcpCommunicationSpi	TcpCommunicationSpi.setIdleConnectionTimeout(long idleConnTimeout) Sets maximum idle connection timeout upon which a connection to client will be closed.
TcpCommunicationSpi	TcpCommunicationSpi.setLocalAddress(String locAddr) Sets local host address for socket binding.
TcpCommunicationSpi	TcpCommunicationSpi.setLocalPort(int locPort) Sets local port for socket binding.
TcpCommunicationSpi	TcpCommunicationSpi.setLocalPortRange(int locPortRange) Sets local port range for local host ports (value must greater than or equal to 0).
TcpCommunicationSpi	TcpCommunicationSpi.setMaxConnectTimeout(long maxConnTimeout) Sets maximum connect timeout.
TcpCommunicationSpi	TcpCommunicationSpi.setMessageQueueLimit(int msgQueueLimit) Sets message queue limit for incoming and outgoing messages.
TcpCommunicationSpi	TcpCommunicationSpi.setName(String name) Sets SPI name.
TcpCommunicationSpi	TcpCommunicationSpi.setReconnectCount(int reconCnt) Sets maximum number of reconnect attempts used when establishing connection with remote nodes.
TcpCommunicationSpi	TcpCommunicationSpi.setSelectorsCount(int selectorsCnt) Sets the count of selectors te be used in TCP server.
TcpCommunicationSpi	TcpCommunicationSpi.setSelectorSpins(long selectorSpins) Defines how many non-blocking selector.selectNow() should be made before falling into selector.select(long) in NIO server.
TcpCommunicationSpi	TcpCommunicationSpi.setSharedMemoryPort(int shmemPort) Sets local port to accept shared memory connections.
TcpCommunicationSpi	TcpCommunicationSpi.setSlowClientQueueLimit(int slowClientQueueLimit) Sets slow client queue limit.
TcpCommunicationSpi	TcpCommunicationSpi.setSocketReceiveBuffer(int sockRcvBuf) Sets receive buffer size for sockets created or accepted by this SPI.
TcpCommunicationSpi	TcpCommunicationSpi.setSocketSendBuffer(int sockSndBuf) Sets send buffer size for sockets created or accepted by this SPI.
TcpCommunicationSpi	TcpCommunicationSpi.setSocketWriteTimeout(long sockWriteTimeout) Sets socket write timeout for TCP connection.
TcpCommunicationSpi	TcpCommunicationSpi.setTcpNoDelay(boolean tcpNoDelay) Sets value for TCP_NODELAY socket option.
TcpCommunicationSpi	TcpCommunicationSpi.setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize) Sets maximum number of stored unacknowledged messages per connection to node.
TcpCommunicationSpi	TcpCommunicationSpi.setUsePairedConnections(boolean usePairedConnections) Set this to true if TcpCommunicationSpi should maintain connection for outgoing and incoming messages separately.