com.gigaspaces.internal.cluster.node.impl.packets.data

Interface IReplicationTransactionalPacketEntryData

All Superinterfaces:

Externalizable, IReplicationPacketEntryData, ISwapExternalizable, Serializable

All Known Implementing Classes:

ChangeReplicationPacketData, PartialUpdateReplicationPacketData, RemoveByUIDReplicationPacketData, RemoveReplicationPacketData, UpdateReplicationPacketData, WriteReplicationPacketData

public interface IReplicationTransactionalPacketEntryData
extends IReplicationPacketEntryData

Method Summary

Modifier and Type	Method and Description
void	batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback executionCallback)
boolean	beforeDelayedReplication() If the replication of this packet is delayed due to being asynchronous by nature or the target was disconnected when the replication packet was generated, this method is called before the actual replication and the implementor can modify the packet accordingly, mostly relevant for time to live update.
IReplicationTransactionalPacketEntryData	clone()
void	executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
IReplicationFilterEntry	toFilterEntry(SpaceTypeManager spaceTypeManager)

Methods inherited from interface com.gigaspaces.internal.cluster.node.impl.packets.data.IReplicationPacketEntryData

containsFullEntryData, filterIfNotPresentInReplicaState, getOperationId, getOperationType, getOrderCode, getUid, isBackupOnly, isFromGateway, isTransient, requiresRecoveryDuplicationProtection

Methods inherited from interface java.io.Externalizable

readExternal, writeExternal

Methods inherited from interface com.gigaspaces.internal.server.space.redolog.storage.bytebuffer.ISwapExternalizable

readFromSwap, writeToSwap

Method Detail

toFilterEntry

IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

executeTransactional

void executeTransactional(IReplicationInContext context,
                          ITransactionalExecutionCallback transactionExecutionCallback,
                          Transaction transaction,
                          boolean twoPhaseCommit)
                   throws Exception

Throws:

Exception

batchExecuteTransactional

void batchExecuteTransactional(IReplicationInBatchContext context,
                               ITransactionalBatchExecutionCallback executionCallback)
                        throws Exception

Throws:

Exception

clone

IReplicationTransactionalPacketEntryData clone()

beforeDelayedReplication

boolean beforeDelayedReplication()

If the replication of this packet is delayed due to being asynchronous by nature or the target was disconnected when the replication packet was generated, this method is called before the actual replication and the implementor can modify the packet accordingly, mostly relevant for time to live update. If the method returns false the packet is no longer relevant and it is discarded