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

Class SingleUidReplicationPacketData

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

CancelLeaseReplicationPacketData, ChangeReplicationPacketData, EntryLeaseExpiredReplicationPacketData, EvictReplicationPacketData, ExtendEntryLeaseReplicationPacketData, ExtendNotifyTemplateLeaseReplicationPacketData, NotifyTemplateLeaseExpiredReplicationPacketData, RemoveByUIDReplicationPacketData, RemoveNotifyTemplateReplicationPacketData

public abstract class SingleUidReplicationPacketData
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

Field Summary

Fields

Modifier and Type	Field and Description
protected IEntryData	_entryData

Constructor Summary

Constructors

Constructor and Description
SingleUidReplicationPacketData()
SingleUidReplicationPacketData(String uid, OperationID operationID, boolean isTransient, boolean fromGateway, IEntryData entryData)

Method Summary

Modifier and Type	Method and Description
SingleUidReplicationPacketData	clone()
boolean	containsFullEntryData()
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
protected abstract void	executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler)
protected abstract int	getFilterObjectType()
protected abstract ReplicationOperationType	getFilterOldReplicationOpType()
IEntryData	getMainEntryData()
OperationID	getOperationId()
int	getOrderCode()
IEntryData	getSecondaryEntryData()
protected ITimeToLiveUpdateCallback	getTimeToLiveUpdateCallback()
protected IServerTypeDesc	getTypeDescriptor(SpaceTypeManager spaceTypeManager)
protected abstract String	getTypeName()
String	getUid()
boolean	isTransient()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
protected IReplicationFilterEntry	toFilterEntry(SpaceTypeManager spaceTypeManager)
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, 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, toString, wait, wait, wait

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

beforeDelayedReplication

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.internal.cluster.node.impl.packets.data.IReplicationPacketEntryData

filterIfNotPresentInReplicaState, getOperationType, isBackupOnly

Field Detail

_entryData

protected transient IEntryData _entryData

Constructor Detail

SingleUidReplicationPacketData

public SingleUidReplicationPacketData()

SingleUidReplicationPacketData

public SingleUidReplicationPacketData(String uid,
                                      OperationID operationID,
                                      boolean isTransient,
                                      boolean fromGateway,
                                      IEntryData entryData)

Method Detail

execute

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

Throws:

Exception

executeImpl

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

Throws:

Exception

clone

public SingleUidReplicationPacketData clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationPacketEntryData>

Overrides:

clone 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

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Overrides:

readFromSwap 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

getUid

public String getUid()

toFilterEntry

protected IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntry in class AbstractReplicationPacketSingleEntryData

getTypeDescriptor

protected IServerTypeDesc getTypeDescriptor(SpaceTypeManager spaceTypeManager)

getOrderCode

public int getOrderCode()

isTransient

public boolean isTransient()

getMainEntryData

public IEntryData getMainEntryData()

Specified by:

getMainEntryData in class AbstractReplicationPacketSingleEntryData

getSecondaryEntryData

public IEntryData getSecondaryEntryData()

Specified by:

getSecondaryEntryData in class AbstractReplicationPacketSingleEntryData

getTypeName

protected abstract String getTypeName()

getFilterObjectType

protected abstract int getFilterObjectType()

getFilterOldReplicationOpType

protected abstract ReplicationOperationType getFilterOldReplicationOpType()

getTimeToLiveUpdateCallback

protected ITimeToLiveUpdateCallback getTimeToLiveUpdateCallback()

getOperationId

public OperationID getOperationId()

Specified by:

getOperationId in interface IReplicationPacketEntryData

Overrides:

getOperationId in class AbstractReplicationPacketSingleEntryData

containsFullEntryData

public boolean containsFullEntryData()