TransactionOnePhaseReplicationPacketData
@Deprecated public class TransactionReplicationPacketData extends LinkedList<IReplicationTransactionalPacketEntryData> implements IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>, ITransactionInContext
Modifier and Type | Class and Description |
---|---|
static class |
TransactionReplicationPacketData.FilterIterable
Deprecated.
|
modCount
Constructor and Description |
---|
TransactionReplicationPacketData()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
beforeDelayedReplication()
Deprecated.
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.
|
TransactionReplicationPacketData |
clone()
Deprecated.
|
TransactionReplicationPacketData |
createEmptyMultipleEntryData()
Deprecated.
|
void |
execute(IReplicationInContext context,
IReplicationInFacade inReplicationHandler,
ReplicationPacketDataMediator dataMediator)
Deprecated.
|
TransactionParticipantDataImpl |
getMetaData()
Deprecated.
|
ReplicationMultipleOperationType |
getMultipleOperationType()
Deprecated.
|
OperationID |
getOperationID()
Deprecated.
|
Object |
getRecoveryFilteringId()
Deprecated.
|
IReplicationPacketEntryData |
getSingleEntryData()
Deprecated.
|
ServerTransaction |
getTransaction()
Deprecated.
|
int |
getWeight()
Deprecated.
|
boolean |
isFromGateway()
Deprecated.
|
boolean |
isMultiParticipantData()
Deprecated.
Gets whether this data is part of multiple participants data
|
boolean |
isPartOfBlobstoreBulk()
Deprecated.
|
boolean |
isSingleEntryData()
Deprecated.
|
void |
readExternal(ObjectInput in)
Deprecated.
|
void |
readFromSwap(ObjectInput in)
Deprecated.
|
boolean |
requiresRecoveryFiltering()
Deprecated.
|
void |
setMetaData(TransactionParticipantDataImpl metaData)
Deprecated.
|
void |
setWeight(int weight)
Deprecated.
|
boolean |
supportsReplicationFilter()
Deprecated.
|
Iterable<IReplicationFilterEntry> |
toFilterEntries(SpaceTypeManager spaceTypeManager)
Deprecated.
|
String |
toString()
Deprecated.
|
void |
writeExternal(ObjectOutput out)
Deprecated.
|
void |
writeToSwap(ObjectOutput out)
Deprecated.
|
add, add, addAll, addAll, addFirst, addLast, clear, contains, descendingIterator, element, get, getFirst, getLast, indexOf, lastIndexOf, listIterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, set, size, spliterator, toArray, toArray
iterator
equals, hashCode, listIterator, removeRange, subList
containsAll, isEmpty, removeAll, retainAll
finalize, getClass, notify, notifyAll, wait, wait, wait
add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray
enabledSmartExternalizableWithReference
containsAll, equals, hashCode, isEmpty, iterator, listIterator, removeAll, replaceAll, retainAll, sort, subList
public TransactionReplicationPacketData()
public OperationID getOperationID()
getOperationID
in interface ITransactionInContext
public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException
readExternal
in interface Externalizable
IOException
ClassNotFoundException
public void writeExternal(ObjectOutput out) throws IOException
writeExternal
in interface Externalizable
IOException
public void readFromSwap(ObjectInput in) throws IOException, ClassNotFoundException
readFromSwap
in interface ISwapExternalizable
IOException
ClassNotFoundException
public void writeToSwap(ObjectOutput out) throws IOException
writeToSwap
in interface ISwapExternalizable
IOException
public TransactionReplicationPacketData clone()
clone
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
clone
in class LinkedList<IReplicationTransactionalPacketEntryData>
public boolean isSingleEntryData()
isSingleEntryData
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public IReplicationPacketEntryData getSingleEntryData()
getSingleEntryData
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public void setMetaData(TransactionParticipantDataImpl metaData)
public TransactionParticipantDataImpl getMetaData()
getMetaData
in interface ITransactionInContext
public ServerTransaction getTransaction()
getTransaction
in interface ITransactionInContext
public ReplicationMultipleOperationType getMultipleOperationType()
getMultipleOperationType
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public void execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator) throws Exception
execute
in interface IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>
Exception
public boolean beforeDelayedReplication()
IReplicationPacketData
beforeDelayedReplication
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public boolean supportsReplicationFilter()
supportsReplicationFilter
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public Iterable<IReplicationFilterEntry> toFilterEntries(SpaceTypeManager spaceTypeManager)
toFilterEntries
in interface IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>
public TransactionReplicationPacketData createEmptyMultipleEntryData()
createEmptyMultipleEntryData
in interface IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>
public boolean isPartOfBlobstoreBulk()
isPartOfBlobstoreBulk
in interface IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>
public String toString()
toString
in class AbstractCollection<IReplicationTransactionalPacketEntryData>
public boolean isMultiParticipantData()
IReplicationPacketData
isMultiParticipantData
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public boolean requiresRecoveryFiltering()
requiresRecoveryFiltering
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public Object getRecoveryFilteringId()
getRecoveryFilteringId
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public boolean isFromGateway()
isFromGateway
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public void setWeight(int weight)
setWeight
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
public int getWeight()
getWeight
in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>
Copyright © GigaSpaces.