Class GridDhtTxFinishResponse
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.GridCacheMessage
-
- org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxFinishResponse
-
- org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxFinishResponse
-
- All Implemented Interfaces:
Serializable,Message
public class GridDhtTxFinishResponse extends GridDistributedTxFinishResponse
DHT transaction finish response.- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheMessage
addDepInfo, CACHE_MSG_INDEX_FIELD_NAME, forceAddDepInfo, MAX_CACHE_MSG_LOOKUP_INDEX
-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description GridDhtTxFinishResponse()Empty constructor required byExternalizable.GridDhtTxFinishResponse(int part, GridCacheVersion xid, IgniteUuid futId, int miniId)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleancheckCommitted()voidcheckCommitted(boolean checkCommitted)ThrowablecheckCommittedError()voidcheckCommittedError(Throwable checkCommittedErr)shortdirectType()Gets message type.bytefieldsCount()Gets fields count.voidfinishUnmarshal(GridCacheSharedContext<?,?> ctx, ClassLoader ldr)This method is called after the message is deserialized and is responsible for unmarshalling state marshalled inGridCacheMessage.prepareMarshal(GridCacheSharedContext)method.intminiId()voidprepareMarshal(GridCacheSharedContext<?,?> ctx)This method is called before the whole message is serialized and is responsible for pre-marshalling state.booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.GridCacheReturnreturnValue()voidreturnValue(GridCacheReturn retVal)StringtoString()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.-
Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxFinishResponse
addDeploymentInfo, cacheGroupMessage, futureId, handlerId, isFlag, messageLogger, partition, setFlag, xid
-
Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheMessage
appendFlag, classError, deployInfo, error, finishUnmarshalCacheObjects, finishUnmarshalCacheObjects, ignoreClassErrors, lastAffinityChangedTopologyVersion, lastAffinityChangedTopologyVersion, lookupIndex, marshalCollection, marshalInfo, marshalInfos, marshalInvokeArguments, marshalTx, messageId, nextIndexId, onAckReceived, onClassError, partitionExchangeMessage, prepare, prepareMarshalCacheObject, prepareMarshalCacheObjects, prepareMarshalCacheObjects, prepareObject, prepareObject, topologyVersion, transferExpiryPolicy, unmarshalCollection, unmarshalInfo, unmarshalInfos, unmarshalInvokeArguments, unmarshalTx
-
-
-
-
Constructor Detail
-
GridDhtTxFinishResponse
public GridDhtTxFinishResponse()
Empty constructor required byExternalizable.
-
GridDhtTxFinishResponse
public GridDhtTxFinishResponse(int part, GridCacheVersion xid, IgniteUuid futId, int miniId)- Parameters:
part- Partition.xid- Xid version.futId- Future ID.miniId- Mini future ID.
-
-
Method Detail
-
miniId
public int miniId()
- Returns:
- Mini future ID.
-
checkCommittedError
public Throwable checkCommittedError()
- Returns:
- Error for check committed backup requests.
-
checkCommittedError
public void checkCommittedError(Throwable checkCommittedErr)
- Parameters:
checkCommittedErr- Error for check committed backup requests.
-
checkCommitted
public boolean checkCommitted()
- Returns:
- Check committed flag.
-
checkCommitted
public void checkCommitted(boolean checkCommitted)
- Parameters:
checkCommitted- Check committed flag.
-
prepareMarshal
public void prepareMarshal(GridCacheSharedContext<?,?> ctx) throws IgniteCheckedException
This method is called before the whole message is serialized and is responsible for pre-marshalling state.- Overrides:
prepareMarshalin classGridCacheMessage- Parameters:
ctx- Cache context.- Throws:
IgniteCheckedException- If failed.
-
finishUnmarshal
public void finishUnmarshal(GridCacheSharedContext<?,?> ctx, ClassLoader ldr) throws IgniteCheckedException
This method is called after the message is deserialized and is responsible for unmarshalling state marshalled inGridCacheMessage.prepareMarshal(GridCacheSharedContext)method.- Overrides:
finishUnmarshalin classGridCacheMessage- Parameters:
ctx- Context.ldr- Class loader.- Throws:
IgniteCheckedException- If failed.
-
returnValue
public void returnValue(GridCacheReturn retVal)
- Parameters:
retVal- Return value.
-
returnValue
public GridCacheReturn returnValue()
- Returns:
- Return value.
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.- Specified by:
writeToin interfaceMessage- Overrides:
writeToin classGridDistributedTxFinishResponse- Parameters:
buf- Byte buffer.writer- Writer.- Returns:
- Whether message was fully written.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.- Specified by:
readFromin interfaceMessage- Overrides:
readFromin classGridDistributedTxFinishResponse- Parameters:
buf- Byte buffer.reader- Reader.- Returns:
- Whether message was fully read.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Overrides:
directTypein classGridDistributedTxFinishResponse- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Overrides:
fieldsCountin classGridDistributedTxFinishResponse- Returns:
- Fields count.
-
toString
public String toString()
- Overrides:
toStringin classGridDistributedTxFinishResponse
-
-