public class ExtendEntryLeaseReplicationPacketData extends SingleUidReplicationPacketData implements ITimeToLiveUpdateCallback
AbstractReplicationPacketSingleEntryData.SingleEntryIterator, AbstractReplicationPacketSingleEntryData.SingleFilterIterable
_entryData
Constructor and Description |
---|
ExtendEntryLeaseReplicationPacketData() |
ExtendEntryLeaseReplicationPacketData(String className,
String uid,
boolean isTransient,
IEntryData entryData,
long expirationTime,
long leaseTime,
OperationID operationID,
int routingHash,
boolean isFromGateway) |
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() |
long |
getTimeToLive() |
protected ITimeToLiveUpdateCallback |
getTimeToLiveUpdateCallback() |
protected String |
getTypeName() |
void |
readExternal(ObjectInput in) |
void |
readFromSwap(ObjectInput in) |
String |
toString() |
void |
updateTimeToLive(long newTimeToLive) |
void |
writeExternal(ObjectOutput out) |
void |
writeToSwap(ObjectOutput out) |
clone, containsFullEntryData, execute, getMainEntryData, getOperationId, getOrderCode, getSecondaryEntryData, getTypeDescriptor, getUid, isTransient, toFilterEntry
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
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
enabledSmartExternalizableWithReference
isBackupOnly
public ExtendEntryLeaseReplicationPacketData()
public ExtendEntryLeaseReplicationPacketData(String className, String uid, boolean isTransient, IEntryData entryData, long expirationTime, long leaseTime, OperationID operationID, int routingHash, boolean isFromGateway)
protected void executeImpl(IReplicationInContext context, IReplicationInFacade inReplicationHandler) throws Exception
executeImpl
in class SingleUidReplicationPacketData
Exception
public boolean beforeDelayedReplication()
IReplicationPacketData
beforeDelayedReplication
in interface IReplicationPacketData<IReplicationPacketEntryData>
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
readExternal
in class SingleUidReplicationPacketData
IOException
ClassNotFoundException
public void readFromSwap(ObjectInput in) throws IOException, ClassNotFoundException
readFromSwap
in interface ISwapExternalizable
readFromSwap
in class SingleUidReplicationPacketData
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
writeExternal
in class SingleUidReplicationPacketData
IOException
public void writeToSwap(ObjectOutput out) throws IOException
writeToSwap
in interface ISwapExternalizable
writeToSwap
in class SingleUidReplicationPacketData
IOException
protected String getTypeName()
getTypeName
in class SingleUidReplicationPacketData
protected ReplicationOperationType getFilterOldReplicationOpType()
getFilterOldReplicationOpType
in class SingleUidReplicationPacketData
public ReplicationSingleOperationType getOperationType()
getOperationType
in interface IReplicationPacketEntryData
protected int getFilterObjectType()
getFilterObjectType
in class SingleUidReplicationPacketData
protected ITimeToLiveUpdateCallback getTimeToLiveUpdateCallback()
getTimeToLiveUpdateCallback
in class SingleUidReplicationPacketData
public void updateTimeToLive(long newTimeToLive)
updateTimeToLive
in interface ITimeToLiveUpdateCallback
public long getTimeToLive()
getTimeToLive
in interface ITimeToLiveUpdateCallback
public boolean filterIfNotPresentInReplicaState()
filterIfNotPresentInReplicaState
in interface IReplicationPacketEntryData
Copyright © GigaSpaces.