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

Class DiscardReplicationPacketData

java.lang.Object

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

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

All Implemented Interfaces:

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

public class DiscardReplicationPacketData
extends AbstractReplicationPacketSingleEntryData

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
DiscardReplicationPacketData()

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.
boolean	containsFullEntryData()
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
boolean	filterIfNotPresentInReplicaState()
IEntryData	getMainEntryData()
ReplicationSingleOperationType	getOperationType()
int	getOrderCode()
IEntryData	getSecondaryEntryData()
String	getTypeName()
String	getUid()
static DiscardReplicationPacketData	instance()
boolean	isTransient()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
boolean	supportsReplicationFilter()
protected IReplicationFilterEntry	toFilterEntry(SpaceTypeManager spaceTypeManager)
String	toString()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)

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

add, addAll, clear, clone, contains, containsAll, createEmptyMultipleEntryData, deserializeEntryData, getBlobstoreBulkId, getCustomContent, getMainTypeName, getMultipleOperationType, getOperationId, 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 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

DiscardReplicationPacketData

public DiscardReplicationPacketData()

Method Detail

instance

public static final DiscardReplicationPacketData instance()

execute

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

Throws:

Exception

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

getMainEntryData

public IEntryData getMainEntryData()

Specified by:

getMainEntryData in class AbstractReplicationPacketSingleEntryData

getSecondaryEntryData

public IEntryData getSecondaryEntryData()

Specified by:

getSecondaryEntryData in class AbstractReplicationPacketSingleEntryData

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractReplicationPacketSingleEntryData

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractReplicationPacketSingleEntryData

Throws:

IOException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class AbstractReplicationPacketSingleEntryData

Throws:

IOException

supportsReplicationFilter

public boolean supportsReplicationFilter()

Specified by:

supportsReplicationFilter in interface IReplicationPacketData<IReplicationPacketEntryData>

Overrides:

supportsReplicationFilter in class AbstractReplicationPacketSingleEntryData

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class AbstractReplicationPacketSingleEntryData

Throws:

IOException

ClassNotFoundException

getUid

public String getUid()

getTypeName

public String getTypeName()

Specified by:

getTypeName in interface IReplicationPacketEntryData

Overrides:

getTypeName in class AbstractReplicationPacketSingleEntryData

toFilterEntry

protected IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntry in class AbstractReplicationPacketSingleEntryData

getOperationType

public ReplicationSingleOperationType getOperationType()

getOrderCode

public int getOrderCode()

toString

public String toString()

Overrides:

toString in class Object

isTransient

public boolean isTransient()

filterIfNotPresentInReplicaState

public boolean filterIfNotPresentInReplicaState()

containsFullEntryData

public boolean containsFullEntryData()