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

Class SingleReplicationPacketData

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

CancelLeaseFullReplicationPacketData, EntryLeaseExpiredFullReplicationPacketData, InsertNotifyTemplateReplicationPacketData, RemoveReplicationPacketData, UpdateReplicationPacketData, WriteReplicationPacketData

public abstract class SingleReplicationPacketData
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
SingleReplicationPacketData()
SingleReplicationPacketData(IEntryPacket entry, boolean fromGateway)

Method Summary

Modifier and Type	Method and Description
SingleReplicationPacketData	clone()
SingleReplicationPacketData	cloneWithEntryPacket(IEntryPacket entryPacket)
boolean	containsFullEntryData()
IEntryPacket	getEntryPacket()
protected abstract int	getFilterObjectType(IServerTypeDesc serverTypeDesc)
protected abstract ReplicationOperationType	getFilterReplicationOpType()
IEntryData	getMainEntryData()
OperationID	getOperationId()
int	getOrderCode()
IEntryData	getSecondaryEntryData()
protected IServerTypeDesc	getTypeDescriptor(SpaceTypeManager spaceTypeManager)
String	getUid()
boolean	isTransient()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
IReplicationFilterEntry	toFilterEntry(SpaceTypeManager spaceTypeManager)
protected boolean	updateEntryPacketTimeToLiveIfNeeded(long expirationTime)
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, 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, toString, wait, wait, wait

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

execute

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

Constructor Detail

SingleReplicationPacketData

public SingleReplicationPacketData()

SingleReplicationPacketData

public SingleReplicationPacketData(IEntryPacket entry,
                                   boolean fromGateway)

Method Detail

clone

public SingleReplicationPacketData clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationPacketEntryData>

Overrides:

clone in class AbstractReplicationPacketSingleEntryData

cloneWithEntryPacket

public SingleReplicationPacketData cloneWithEntryPacket(IEntryPacket entryPacket)

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

getEntryPacket

public IEntryPacket getEntryPacket()

toFilterEntry

public IReplicationFilterEntry toFilterEntry(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntry in class AbstractReplicationPacketSingleEntryData

getTypeDescriptor

protected IServerTypeDesc getTypeDescriptor(SpaceTypeManager spaceTypeManager)

getOrderCode

public int getOrderCode()

isTransient

public boolean isTransient()

getFilterObjectType

protected abstract int getFilterObjectType(IServerTypeDesc serverTypeDesc)

getFilterReplicationOpType

protected abstract ReplicationOperationType getFilterReplicationOpType()

getMainEntryData

public IEntryData getMainEntryData()

Specified by:

getMainEntryData in class AbstractReplicationPacketSingleEntryData

getSecondaryEntryData

public IEntryData getSecondaryEntryData()

Specified by:

getSecondaryEntryData in class AbstractReplicationPacketSingleEntryData

getOperationId

public OperationID getOperationId()

Specified by:

getOperationId in interface IReplicationPacketEntryData

Overrides:

getOperationId in class AbstractReplicationPacketSingleEntryData

containsFullEntryData

public boolean containsFullEntryData()

updateEntryPacketTimeToLiveIfNeeded

protected boolean updateEntryPacketTimeToLiveIfNeeded(long expirationTime)