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

Class InsertNotifyTemplateReplicationPacketData

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

All Implemented Interfaces:

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

public class InsertNotifyTemplateReplicationPacketData
extends SingleReplicationPacketData

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	Description
InsertNotifyTemplateReplicationPacketData()
InsertNotifyTemplateReplicationPacketData(ITemplatePacket templatePacket, String templateUid, NotifyInfo notifyInfo, long expirationTime)

Method Summary

Modifier and Type	Method	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()
NotifyInfo	getNotifyInfo()
ReplicationSingleOperationType	getOperationType()
String	getUid()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
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.SingleReplicationPacketData

clone, cloneWithEntryPacket, containsFullEntryData, getEntryPacket, getMainEntryData, getOperationId, getOrderCode, getSecondaryEntryData, getTypeDescriptor, getTypeName, isTransient, updateEntryPacketTimeToLiveIfNeeded

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, toArray

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

isBackupOnly

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

InsertNotifyTemplateReplicationPacketData

public InsertNotifyTemplateReplicationPacketData()

InsertNotifyTemplateReplicationPacketData

public InsertNotifyTemplateReplicationPacketData(ITemplatePacket templatePacket,
 String templateUid,
 NotifyInfo notifyInfo,
 long expirationTime)

Method Details

getNotifyInfo

public NotifyInfo getNotifyInfo()

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

getUid

public String getUid()

Specified by:

getUid in interface IReplicationPacketEntryData

Overrides:

getUid in class SingleReplicationPacketData

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class SingleReplicationPacketData

Throws:

IOException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Overrides:

writeToSwap in class SingleReplicationPacketData

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class SingleReplicationPacketData

Throws:

IOException

ClassNotFoundException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap in class SingleReplicationPacketData

Throws:

IOException

ClassNotFoundException

toFilterEntry

public IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

Overrides:

toFilterEntry in class SingleReplicationPacketData

getFilterObjectType

protected int getFilterObjectType(IServerTypeDesc serverTypeDesc)

Specified by:

getFilterObjectType in class SingleReplicationPacketData

getFilterReplicationOpType

protected ReplicationOperationType getFilterReplicationOpType()

Specified by:

getFilterReplicationOpType in class SingleReplicationPacketData

getOperationType

public ReplicationSingleOperationType getOperationType()

toString

public String toString()

Overrides:

toString in class Object

filterIfNotPresentInReplicaState

public boolean filterIfNotPresentInReplicaState()