@MXBeanDescription(value="MBean provide access to TCP-based communication SPI.") public interface TcpCommunicationSpiMBean extends IgniteSpiManagementMBean
Modifier and Type | Method and Description |
---|---|
int |
getAckSendThreshold()
Gets number of received messages per connection to node after which acknowledgment message is sent.
|
double |
getBufferSizeRatio()
Gets the buffer size ratio for this SPI.
|
long |
getConnectionBufferFlushFrequency()
Gets connection buffer flush frequency.
|
int |
getConnectionBufferSize()
Gets connection buffer size.
|
long |
getConnectTimeout()
Gets connect timeout used when establishing connection
with remote nodes.
|
long |
getIdleConnectionTimeout()
Gets maximum idle connection time upon which idle connections
will be closed.
|
String |
getLocalAddress()
Gets local host address for socket binding.
|
int |
getLocalPort()
Gets local port for socket binding.
|
int |
getLocalPortRange()
Gets maximum number of local ports tried if all previously
tried ports are occupied.
|
long |
getMaxConnectTimeout()
Gets maximum connect timeout.
|
int |
getMessageQueueLimit()
Gets message queue limit for incoming and outgoing messages.
|
int |
getMinimumBufferedMessageCount()
Gets the minimum number of messages for this SPI, that are buffered
prior to sending.
|
int |
getOutboundMessagesQueueSize()
Gets outbound messages queue size.
|
long |
getReceivedBytesCount()
Gets received bytes count.
|
int |
getReceivedMessagesCount()
Gets received messages count.
|
int |
getReconnectCount()
Gets maximum number of reconnect attempts used when establishing connection
with remote nodes.
|
int |
getSelectorsCount()
Gets count of selectors used in TCP server.
|
long |
getSentBytesCount()
Gets sent bytes count.
|
int |
getSentMessagesCount()
Gets sent messages count.
|
int |
getSocketReceiveBuffer()
Gets receive buffer size for sockets created or accepted by this SPI.
|
int |
getSocketSendBuffer()
Gets send buffer size for sockets created or accepted by this SPI.
|
long |
getSocketWriteTimeout()
Gets socket write timeout for TCP connections.
|
int |
getUnacknowledgedMessagesBufferSize()
Gets maximum number of stored unacknowledged messages per connection to node.
|
boolean |
isDirectBuffer()
Gets flag that indicates whether direct or heap allocated buffer is used.
|
boolean |
isDirectSendBuffer()
Gets flag defining whether direct send buffer should be used.
|
boolean |
isTcpNoDelay()
Gets value for
TCP_NODELAY socket option. |
void |
setConnectionBufferFlushFrequency(long connBufFlushFreq)
Sets connection buffer flush frequency.
|
getIgniteHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted
@MXBeanDescription(value="Grid node IP address.") String getLocalAddress()
@MXBeanDescription(value="Port number.") int getLocalPort()
@MXBeanDescription(value="Local port range.") int getLocalPortRange()
@MXBeanDescription(value="Maximum idle connection time.") long getIdleConnectionTimeout()
@MXBeanDescription(value="Flag that indicates whether direct or heap allocated buffer is used.") boolean isDirectBuffer()
@MXBeanDescription(value="Count of selectors used in TCP server.") int getSelectorsCount()
@MXBeanDescription(value="Sent messages count.") int getSentMessagesCount()
@MXBeanDescription(value="Sent bytes count.") long getSentBytesCount()
@MXBeanDescription(value="Received messages count.") int getReceivedMessagesCount()
@MXBeanDescription(value="Received bytes count.") long getReceivedBytesCount()
@MXBeanDescription(value="Outbound messages queue size.") int getOutboundMessagesQueueSize()
@MXBeanDescription(value="Connect timeout.") long getConnectTimeout()
@MXBeanDescription(value="Maximum connect timeout.") long getMaxConnectTimeout()
@MXBeanDescription(value="Reconnect count on connection failure.") int getReconnectCount()
@MXBeanDescription(value="TCP_NODELAY socket option value.") boolean isTcpNoDelay()
TCP_NODELAY
socket option.True
if TCP delay is disabled.@MXBeanDescription(value="Connection buffer flush frequency.") long getConnectionBufferFlushFrequency()
Client connections to other nodes in topology use buffered output. This frequency defines how often system will advice to flush connection buffer.
@MXBeanDescription(value="Sets connection buffer flush frequency.") void setConnectionBufferFlushFrequency(long connBufFlushFreq)
Client connections to other nodes in topology use buffered output. This frequency defines how often system will advice to flush connection buffer.
If not provided, default value is TcpCommunicationSpi.DFLT_CONN_BUF_FLUSH_FREQ
.
This property is used only if getConnectionBufferSize()
is greater than 0
.
connBufFlushFreq
- Flush frequency.getConnectionBufferSize()
@MXBeanDescription(value="Connection buffer size.") int getConnectionBufferSize()
If set to 0
connection buffer is disabled.
@MXBeanDescription(value="Direct send buffer.") boolean isDirectSendBuffer()
True
if direct buffers should be used.@MXBeanDescription(value="Socket receive buffer.") int getSocketReceiveBuffer()
If not provided, default is TcpCommunicationSpi.DFLT_SOCK_BUF_SIZE
.
@MXBeanDescription(value="Socket send buffer.") int getSocketSendBuffer()
If not provided, default is TcpCommunicationSpi.DFLT_SOCK_BUF_SIZE
.
@MXBeanDescription(value="Message queue size limit.") int getMessageQueueLimit()
@MXBeanDescription(value="Minimum buffered message count.") int getMinimumBufferedMessageCount()
@MXBeanDescription(value="Buffer size ratio.") double getBufferSizeRatio()
@MXBeanDescription(value="Socket write timeout.") long getSocketWriteTimeout()
@MXBeanDescription(value="Number of received messages after which acknowledgment is sent.") int getAckSendThreshold()
@MXBeanDescription(value="Maximum number of unacknowledged messages.") int getUnacknowledgedMessagesBufferSize()
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015