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

Class ChangeReplicationPacketData

java.lang.Object

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

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

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

All Implemented Interfaces:

ITimeToLiveUpdateCallback, IExecutableReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketData<IReplicationPacketEntryData>, IReplicationPacketEntryData, IReplicationTransactionalPacketEntryData, ISwapExternalizable, SmartExternalizable, Externalizable, Serializable, Cloneable, Iterable<IReplicationPacketEntryData>, Collection<IReplicationPacketEntryData>

public class ChangeReplicationPacketData
extends SingleUidReplicationPacketData
implements IReplicationTransactionalPacketEntryData, ITimeToLiveUpdateCallback

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

AbstractReplicationPacketSingleEntryData.SingleEntryIterator, AbstractReplicationPacketSingleEntryData.SingleFilterIterable

Field Summary

Fields

Modifier and Type	Field and Description
static ThreadLocal<Boolean>	forRecovery

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleUidReplicationPacketData

_entryData

Constructor Summary

Constructors

Constructor and Description
ChangeReplicationPacketData()
ChangeReplicationPacketData(String typeName, String uid, Object id, int version, int previousVersion, boolean isTransient, IEntryData entryData, OperationID operationID, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, IEntryData previousEntryData, long timeToLive, long expirationTime, boolean fromGateway)

Method Summary

Modifier and Type	Method and Description
void	batchExecuteTransactional(IReplicationInBatchContext context, ITransactionalBatchExecutionCallback transactionExecutionCallback)
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.
ChangeReplicationPacketData	clone()
boolean	containsFullEntryData()
protected void	executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
void	executeTransactional(IReplicationInContext context, ITransactionalExecutionCallback transactionExecutionCallback, Transaction transaction, boolean twoPhaseCommit)
boolean	filterIfNotPresentInReplicaState()
Collection<SpaceEntryMutator>	getCustomContent()
long	getExpirationTime()
protected int	getFilterObjectType()
protected ReplicationOperationType	getFilterOldReplicationOpType()
ReplicationSingleOperationType	getOperationType()
IEntryData	getSecondaryEntryData()
long	getTimeToLive()
protected ITimeToLiveUpdateCallback	getTimeToLiveUpdateCallback()
String	getTypeName()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
boolean	supportsReplicationFilter()
IReplicationFilterEntry	toFilterEntry(SpaceTypeManager spaceTypeManager)
String	toString()
void	updateTimeToLive(long newTimeToLive)
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleUidReplicationPacketData

execute, getMainEntryData, getOperationId, getOrderCode, getTypeDescriptor, getUid, isTransient

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractReplicationPacketSingleEntryData

add, addAll, clear, contains, containsAll, createEmptyMultipleEntryData, deserializeEntryData, getBlobstoreBulkId, getMainTypeName, getMultipleOperationType, getRecoveryFilteringId, getSingleEntryData, getWeight, isEmpty, isFromGateway, isMultiParticipantData, isPartOfBlobstoreBulk, isSingleEntryData, iterator, remove, removeAll, requiresRecoveryDuplicationProtection, requiresRecoveryFiltering, retainAll, serializeEntryData, setBlobstoreBulkId, setWeight, size, toArray, toArray, toFilterEntries, updateTimeToLiveIfNeeded

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

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

getOperationId, getOrderCode, getUid, isBackupOnly, isFromGateway, isTransient, requiresRecoveryDuplicationProtection

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Field Detail

forRecovery

public static final ThreadLocal<Boolean> forRecovery

Constructor Detail

ChangeReplicationPacketData

public ChangeReplicationPacketData()

ChangeReplicationPacketData

public ChangeReplicationPacketData(String typeName,
                                   String uid,
                                   Object id,
                                   int version,
                                   int previousVersion,
                                   boolean isTransient,
                                   IEntryData entryData,
                                   OperationID operationID,
                                   int routingHash,
                                   Collection<SpaceEntryMutator> spaceEntryMutators,
                                   IEntryData previousEntryData,
                                   long timeToLive,
                                   long expirationTime,
                                   boolean fromGateway)

Method Detail

getOperationType

public ReplicationSingleOperationType getOperationType()

Specified by:

getOperationType in interface IReplicationPacketEntryData

filterIfNotPresentInReplicaState

public boolean filterIfNotPresentInReplicaState()

Specified by:

filterIfNotPresentInReplicaState in interface IReplicationPacketEntryData

executeTransactional

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

Specified by:

executeTransactional in interface IReplicationTransactionalPacketEntryData

Throws:

Exception

batchExecuteTransactional

public void batchExecuteTransactional(IReplicationInBatchContext context,
                                      ITransactionalBatchExecutionCallback transactionExecutionCallback)
                               throws Exception

Specified by:

batchExecuteTransactional in interface IReplicationTransactionalPacketEntryData

Throws:

Exception

beforeDelayedReplication

public boolean beforeDelayedReplication()

Description copied from interface: IReplicationTransactionalPacketEntryData

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

Specified by:

beforeDelayedReplication in interface IReplicationPacketData<IReplicationPacketEntryData>

Specified by:

beforeDelayedReplication in interface IReplicationTransactionalPacketEntryData

executeImpl

protected void executeImpl(IReplicationInContext context,
                           IReplicationInFacade inReplicationHandler)
                    throws Exception

Specified by:

executeImpl in class SingleUidReplicationPacketData

Throws:

Exception

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface IReplicationPacketEntryData

Overrides:

getTypeName in class AbstractReplicationPacketSingleEntryData

getFilterObjectType

protected int getFilterObjectType()

Specified by:

getFilterObjectType in class SingleUidReplicationPacketData

supportsReplicationFilter

public boolean supportsReplicationFilter()

Specified by:

supportsReplicationFilter in interface IReplicationPacketData<IReplicationPacketEntryData>

Overrides:

supportsReplicationFilter in class AbstractReplicationPacketSingleEntryData

toFilterEntry

public IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntry in interface IReplicationTransactionalPacketEntryData

Overrides:

toFilterEntry in class SingleUidReplicationPacketData

getFilterOldReplicationOpType

protected ReplicationOperationType getFilterOldReplicationOpType()

Specified by:

getFilterOldReplicationOpType in class SingleUidReplicationPacketData

getTimeToLiveUpdateCallback

protected ITimeToLiveUpdateCallback getTimeToLiveUpdateCallback()

Overrides:

getTimeToLiveUpdateCallback in class SingleUidReplicationPacketData

updateTimeToLive

public void updateTimeToLive(long newTimeToLive)

Specified by:

updateTimeToLive in interface ITimeToLiveUpdateCallback

getTimeToLive

public long getTimeToLive()

Specified by:

getTimeToLive in interface ITimeToLiveUpdateCallback

getSecondaryEntryData

public IEntryData getSecondaryEntryData()

Overrides:

getSecondaryEntryData in class SingleUidReplicationPacketData

containsFullEntryData

public boolean containsFullEntryData()

Specified by:

containsFullEntryData in interface IReplicationPacketEntryData

Overrides:

containsFullEntryData in class SingleUidReplicationPacketData

getCustomContent

public Collection<SpaceEntryMutator> getCustomContent()

Overrides:

getCustomContent in class AbstractReplicationPacketSingleEntryData

clone

public ChangeReplicationPacketData clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationPacketEntryData>

Specified by:

clone in interface IReplicationTransactionalPacketEntryData

Overrides:

clone in class SingleUidReplicationPacketData

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SingleUidReplicationPacketData

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SingleUidReplicationPacketData

Throws:

IOException

ClassNotFoundException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class SingleUidReplicationPacketData

Throws:

IOException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class SingleUidReplicationPacketData

Throws:

IOException

ClassNotFoundException

getExpirationTime

public long getExpirationTime()

toString

public String toString()

Overrides:

toString in class Object