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

Class RemoveNotifyTemplateReplicationPacketData

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.RemoveNotifyTemplateReplicationPacketData

All Implemented Interfaces:

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

public class RemoveNotifyTemplateReplicationPacketData
extends SingleUidReplicationPacketData

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 inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.SingleUidReplicationPacketData

_entryData

Constructor Summary

Constructors

Constructor and Description
RemoveNotifyTemplateReplicationPacketData()
RemoveNotifyTemplateReplicationPacketData(String className, NotifyInfo notifyInfo, int objectType, String templateUid, boolean isTransient, IEntryData entryData, OperationID operationID)

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.
protected void	executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
boolean	filterIfNotPresentInReplicaState()
protected int	getFilterObjectType()
protected ReplicationOperationType	getFilterOldReplicationOpType()
ReplicationSingleOperationType	getOperationType()
String	getTypeName()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
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.SingleUidReplicationPacketData

clone, containsFullEntryData, execute, getMainEntryData, getOperationId, getOrderCode, getSecondaryEntryData, getTimeToLiveUpdateCallback, 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, getCustomContent, getMainTypeName, getMultipleOperationType, getRecoveryFilteringId, getSingleEntryData, isEmpty, isFromGateway, isMultiParticipantData, isPartOfBlobstoreBulk, isSingleEntryData, iterator, remove, removeAll, requiresRecoveryDuplicationProtection, requiresRecoveryFiltering, retainAll, serializeEntryData, setBlobstoreBulkId, 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

Constructor Detail

RemoveNotifyTemplateReplicationPacketData

public RemoveNotifyTemplateReplicationPacketData()

RemoveNotifyTemplateReplicationPacketData

public RemoveNotifyTemplateReplicationPacketData(String className,
                                                 NotifyInfo notifyInfo,
                                                 int objectType,
                                                 String templateUid,
                                                 boolean isTransient,
                                                 IEntryData entryData,
                                                 OperationID operationID)

Method Detail

getTypeName

public String getTypeName()

Specified by:

getTypeName 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

executeImpl

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

Specified by:

executeImpl in class SingleUidReplicationPacketData

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

toFilterEntry

protected IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

Overrides:

toFilterEntry in class SingleUidReplicationPacketData

getFilterOldReplicationOpType

protected ReplicationOperationType getFilterOldReplicationOpType()

Specified by:

getFilterOldReplicationOpType in class SingleUidReplicationPacketData

getOperationType

public ReplicationSingleOperationType getOperationType()

getFilterObjectType

protected int getFilterObjectType()

Specified by:

getFilterObjectType in class SingleUidReplicationPacketData

filterIfNotPresentInReplicaState

public boolean filterIfNotPresentInReplicaState()

toString

public String toString()

Overrides:

toString in class Object