Class HandshakeMessage
- java.lang.Object
-
- org.apache.ignite.spi.communication.tcp.messages.HandshakeMessage
-
- All Implemented Interfaces:
Serializable,Message
- Direct Known Subclasses:
HandshakeMessage2
public class HandshakeMessage extends Object implements Message
Handshake message.- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static intMESSAGE_FULL_SIZEFull message size (with message type) in bytes.-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description HandshakeMessage()Default constructor required byMessage.HandshakeMessage(UUID nodeId, long connectCnt, long rcvCnt)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longconnectCount()intconnectionIndex()shortdirectType()Gets message type.bytefieldsCount()Gets fields count.intgetMessageSize()UUIDnodeId()voidonAckReceived()Method called when ack message received.booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.longreceived()StringtoString()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.
-
-
-
Field Detail
-
MESSAGE_FULL_SIZE
public static final int MESSAGE_FULL_SIZE
Full message size (with message type) in bytes.- See Also:
- Constant Field Values
-
-
Method Detail
-
connectionIndex
public int connectionIndex()
- Returns:
- Connection index.
-
connectCount
public long connectCount()
- Returns:
- Connect count.
-
received
public long received()
- Returns:
- Number of received messages.
-
nodeId
public UUID nodeId()
- Returns:
- Node ID.
-
getMessageSize
public int getMessageSize()
- Returns:
- Message size in bytes.
-
onAckReceived
public void onAckReceived()
Method called when ack message received.- Specified by:
onAckReceivedin interfaceMessage
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Returns:
- Fields count.
-
-