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

Class CancelLeaseFullReplicationPacketData

java.lang.Object

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

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

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

All Implemented Interfaces:

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

public class CancelLeaseFullReplicationPacketData
extends SingleReplicationPacketData

Since:

9.0

Author:

Dan Kilman

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

Constructor Summary

Constructors

Constructor and Description
CancelLeaseFullReplicationPacketData()
CancelLeaseFullReplicationPacketData(IEntryPacket entry, boolean fromGateway)

Method Summary

Modifier and Type	Method and Description
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.
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
boolean	filterIfNotPresentInReplicaState()
protected int	getFilterObjectType(IServerTypeDesc serverTypeDesc)
protected ReplicationOperationType	getFilterReplicationOpType()
ReplicationSingleOperationType	getOperationType()
String	toString()

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

clone, cloneWithEntryPacket, containsFullEntryData, getEntryPacket, getMainEntryData, getOperationId, getOrderCode, getSecondaryEntryData, getTypeDescriptor, getTypeName, getUid, isTransient, readExternal, readFromSwap, toFilterEntry, updateEntryPacketTimeToLiveIfNeeded, writeExternal, writeToSwap

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

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

isBackupOnly

Constructor Detail

CancelLeaseFullReplicationPacketData

public CancelLeaseFullReplicationPacketData()

CancelLeaseFullReplicationPacketData

public CancelLeaseFullReplicationPacketData(IEntryPacket entry,
                                            boolean fromGateway)

Method Detail

beforeDelayedReplication

public boolean beforeDelayedReplication()

Description copied from interface: IReplicationPacketData

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

getOperationType

public ReplicationSingleOperationType getOperationType()

filterIfNotPresentInReplicaState

public boolean filterIfNotPresentInReplicaState()

toString

public String toString()

Overrides:

toString in class Object

execute

public void execute(IReplicationInContext context,
                    IReplicationInFacade inReplicationHandler,
                    ReplicationPacketDataMediator dataMediator)
             throws Exception

Throws:

Exception

getFilterObjectType

protected int getFilterObjectType(IServerTypeDesc serverTypeDesc)

Specified by:

getFilterObjectType in class SingleReplicationPacketData

getFilterReplicationOpType

protected ReplicationOperationType getFilterReplicationOpType()

Specified by:

getFilterReplicationOpType in class SingleReplicationPacketData