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

Class AbstractTransactionReplicationPacketData

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

java.util.AbstractSequentialList<E>

java.util.LinkedList<IReplicationTransactionalPacketEntryData>

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

All Implemented Interfaces:

ITransactionInContext, IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>, IReplicationPacketData<IReplicationTransactionalPacketEntryData>, ISwapExternalizable, Externalizable, Serializable, Cloneable, Iterable<IReplicationTransactionalPacketEntryData>, Collection<IReplicationTransactionalPacketEntryData>, Deque<IReplicationTransactionalPacketEntryData>, List<IReplicationTransactionalPacketEntryData>, Queue<IReplicationTransactionalPacketEntryData>

Direct Known Subclasses:

AbstractPrepareDependentTransactionReplicationPacketData, TransactionOnePhaseReplicationPacketData, TransactionPrepareReplicationPacketData

public abstract class AbstractTransactionReplicationPacketData
extends LinkedList<IReplicationTransactionalPacketEntryData>
implements IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>, ITransactionInContext

Base class for transaction replication packet data

Since:

9.0

Author:

eitany

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AbstractTransactionReplicationPacketData.FilterIterable

Field Summary

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

Constructor and Description
AbstractTransactionReplicationPacketData()
AbstractTransactionReplicationPacketData(boolean fromGateway)
AbstractTransactionReplicationPacketData(ServerTransaction transaction, boolean fromGateway)

Method Summary

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.
IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>	clone()
protected String	getCustomToString()
TransactionParticipantDataImpl	getMetaData()
OperationID	getOperationID()
Object	getRecoveryFilteringId()
IReplicationPacketEntryData	getSingleEntryData()
ServerTransaction	getTransaction()
boolean	isFromGateway()
boolean	isSingleEntryData()
void	readExternal(ObjectInput in)
void	readFromSwap(ObjectInput in)
protected void	readTransaction(ObjectInput in)
protected void	readTransactionData(ObjectInput in)
void	setMetaData(TransactionParticipantDataImpl metaData)
Iterable<IReplicationFilterEntry>	toFilterEntries(SpaceTypeManager spaceTypeManager)
String	toString()
void	writeExternal(ObjectOutput out)
void	writeToSwap(ObjectOutput out)
protected void	writeTransaction(ObjectOutput out)
protected void	writeTransactionData(ObjectOutput out)

Methods inherited from class java.util.LinkedList

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

Methods inherited from class java.util.AbstractSequentialList

iterator

Methods inherited from class java.util.AbstractList

equals, hashCode, listIterator, removeRange, subList

Methods inherited from class java.util.AbstractCollection

containsAll, isEmpty, removeAll, retainAll

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

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

createEmptyMultipleEntryData, execute, isPartOfBlobstoreBulk

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

getMultipleOperationType, isMultiParticipantData, requiresRecoveryFiltering, supportsReplicationFilter

Methods inherited from interface java.util.Collection

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.List

containsAll, equals, hashCode, isEmpty, iterator, listIterator, removeAll, replaceAll, retainAll, sort, subList

Methods inherited from interface java.util.Deque

iterator

Constructor Detail

AbstractTransactionReplicationPacketData

public AbstractTransactionReplicationPacketData()

AbstractTransactionReplicationPacketData

public AbstractTransactionReplicationPacketData(ServerTransaction transaction,
                                                boolean fromGateway)

AbstractTransactionReplicationPacketData

public AbstractTransactionReplicationPacketData(boolean fromGateway)

Method Detail

getOperationID

public OperationID getOperationID()

Specified by:

getOperationID in interface ITransactionInContext

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

writeTransaction

protected void writeTransaction(ObjectOutput out)
                         throws IOException

Throws:

IOException

readTransaction

protected void readTransaction(ObjectInput in)
                        throws IOException,
                               ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeTransactionData

protected void writeTransactionData(ObjectOutput out)
                             throws IOException

Throws:

IOException

readTransactionData

protected void readTransactionData(ObjectInput in)
                            throws IOException,
                                   ClassNotFoundException

Throws:

IOException

ClassNotFoundException

readFromSwap

public void readFromSwap(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readFromSwap in interface ISwapExternalizable

Throws:

IOException

ClassNotFoundException

writeToSwap

public void writeToSwap(ObjectOutput out)
                 throws IOException

Specified by:

writeToSwap in interface ISwapExternalizable

Throws:

IOException

clone

public IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData> clone()

Specified by:

clone in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

Overrides:

clone in class LinkedList<IReplicationTransactionalPacketEntryData>

isSingleEntryData

public boolean isSingleEntryData()

Specified by:

isSingleEntryData in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

isFromGateway

public boolean isFromGateway()

Specified by:

isFromGateway in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

Returns:

Gets whether this packet was received from gateway replication

getSingleEntryData

public IReplicationPacketEntryData getSingleEntryData()

Specified by:

getSingleEntryData in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

setMetaData

public void setMetaData(TransactionParticipantDataImpl metaData)

getMetaData

public TransactionParticipantDataImpl getMetaData()

Specified by:

getMetaData in interface ITransactionInContext

getTransaction

public ServerTransaction getTransaction()

Specified by:

getTransaction in interface ITransactionInContext

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

Specified by:

beforeDelayedReplication in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

toFilterEntries

public Iterable<IReplicationFilterEntry> toFilterEntries(SpaceTypeManager spaceTypeManager)

Specified by:

toFilterEntries in interface IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>

toString

public String toString()

Overrides:

toString in class AbstractCollection<IReplicationTransactionalPacketEntryData>

getCustomToString

protected String getCustomToString()

getRecoveryFilteringId

public Object getRecoveryFilteringId()

Specified by:

getRecoveryFilteringId in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>