Class UpdateErrors
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.distributed.dht.atomic.UpdateErrors
-
- All Implemented Interfaces:
Serializable,Message
public class UpdateErrors extends Object implements Message
- 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 UpdateErrors()UpdateErrors(IgniteCheckedException err)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description shortdirectType()Gets message type.IgniteCheckedExceptionerror()Collection<KeyCacheObject>failedKeys()bytefieldsCount()Gets fields count.voidonAckReceived()Method called when ack message received.voidonError(IgniteCheckedException err)booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.StringtoString()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.
-
-
-
Constructor Detail
-
UpdateErrors
public UpdateErrors()
-
UpdateErrors
public UpdateErrors(IgniteCheckedException err)
- Parameters:
err- Error.
-
-
Method Detail
-
onError
public void onError(IgniteCheckedException err)
- Parameters:
err- Error.
-
error
public IgniteCheckedException error()
- Returns:
- Error.
-
failedKeys
public Collection<KeyCacheObject> failedKeys()
- Returns:
- Failed keys.
-
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.
-
onAckReceived
public void onAckReceived()
Method called when ack message received.- Specified by:
onAckReceivedin interfaceMessage
-
-