public static class TcpCommunicationSpi.HandshakeMessage extends Object implements Message
| Constructor and Description |
|---|
TcpCommunicationSpi.HandshakeMessage()
Default constructor required by
Message. |
TcpCommunicationSpi.HandshakeMessage(UUID nodeId,
long connectCnt,
long rcvCnt) |
| Modifier and Type | Method and Description |
|---|---|
long |
connectCount() |
byte |
directType()
Gets message type.
|
byte |
fieldsCount()
Gets fields count.
|
UUID |
nodeId() |
void |
onAckReceived()
Method called when ack message received.
|
boolean |
readFrom(ByteBuffer buf,
MessageReader reader)
Reads this message from provided byte buffer.
|
long |
received() |
String |
toString() |
boolean |
writeTo(ByteBuffer buf,
MessageWriter writer)
Writes this message to provided byte buffer.
|
public TcpCommunicationSpi.HandshakeMessage()
Message.public TcpCommunicationSpi.HandshakeMessage(UUID nodeId, long connectCnt, long rcvCnt)
nodeId - Node ID.connectCnt - Connect count.rcvCnt - Number of received messages.public long connectCount()
public long received()
public UUID nodeId()
public void onAckReceived()
onAckReceived in interface Messagepublic boolean writeTo(ByteBuffer buf, MessageWriter writer)
public boolean readFrom(ByteBuffer buf, MessageReader reader)
public byte directType()
directType in interface Messagepublic byte fieldsCount()
fieldsCount in interface Message
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016