Class JobStealingRequest
- java.lang.Object
-
- org.apache.ignite.spi.collision.jobstealing.JobStealingRequest
-
- All Implemented Interfaces:
Serializable
,Message
public class JobStealingRequest extends Object implements Message
Job stealing request.- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description JobStealingRequest()
Required byExternalizable
.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description short
directType()
Gets message type.byte
fieldsCount()
Gets fields count.void
onAckReceived()
Method called when ack message received.boolean
readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.String
toString()
boolean
writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.
-
-
-
Constructor Detail
-
JobStealingRequest
public JobStealingRequest()
Required byExternalizable
.
-
-
Method Detail
-
onAckReceived
public void onAckReceived()
Method called when ack message received.- Specified by:
onAckReceived
in 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:
directType
in interfaceMessage
- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCount
in interfaceMessage
- Returns:
- Fields count.
-
-