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

Class TransactionOnePhaseReplicationPacketData

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

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

All Implemented Interfaces:

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

public class TransactionOnePhaseReplicationPacketData
extends AbstractTransactionReplicationPacketData

Replication packet representing a one phase commit transaction

Since:

9.0

Author:

eitany

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractTransactionReplicationPacketData

AbstractTransactionReplicationPacketData.FilterIterable

Field Summary

Fields inherited from class java.util.AbstractList

modCount

Constructor Summary

Constructors

Constructor	Description
TransactionOnePhaseReplicationPacketData()
TransactionOnePhaseReplicationPacketData(OperationID operationID, boolean fromGateway)

Method Summary

Modifier and Type	Method	Description
IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData>	createEmptyMultipleEntryData()
void	execute(IReplicationInContext context, IReplicationInFacade inReplicationHandler, ReplicationPacketDataMediator dataMediator)
protected String	getCustomToString()
ReplicationMultipleOperationType	getMultipleOperationType()
OperationID	getOperationID()
Object	getRecoveryFilteringId()
boolean	isMultiParticipantData()	Gets whether this data is part of multiple participants data
boolean	isPartOfBlobstoreBulk()
void	readExternal(ObjectInput in)
boolean	requiresRecoveryFiltering()
boolean	supportsReplicationFilter()
void	writeExternal(ObjectOutput out)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.packets.data.operations.AbstractTransactionReplicationPacketData

beforeDelayedReplication, clone, equals, getMetaData, getMvccCommittedGeneration, getSingleEntryData, getTransaction, getWeight, hasMvccCommittedGeneration, hasPersistentMembers, hasTransientMembers, isFromGateway, isMvccRevertGeneration, isSingleEntryData, readFromSwap, setHasPersistentMembersFlag, setHasTransientMembersFlag, setMetaData, setMvccCommittedGeneration, setMvccCommittedGenerationFlag, setMvccRevertGenerationFlag, setWeight, toFilterEntries, toString, unsetHasTransientMembersFlag, writeToSwap, writeTransaction

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

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 java.util.Collection

parallelStream, removeIf, stream, toArray

Methods inherited from interface java.util.Deque

iterator

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface java.util.List

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Constructor Details

TransactionOnePhaseReplicationPacketData

public TransactionOnePhaseReplicationPacketData()

TransactionOnePhaseReplicationPacketData

public TransactionOnePhaseReplicationPacketData(OperationID operationID,
 boolean fromGateway)

Method Details

getOperationID

public OperationID getOperationID()

Specified by:

getOperationID in interface ITransactionInContext

Overrides:

getOperationID in class AbstractTransactionReplicationPacketData

getMultipleOperationType

public ReplicationMultipleOperationType getMultipleOperationType()

execute

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

Throws:

Exception

createEmptyMultipleEntryData

public IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData> createEmptyMultipleEntryData()

isPartOfBlobstoreBulk

public boolean isPartOfBlobstoreBulk()

supportsReplicationFilter

public boolean supportsReplicationFilter()

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class AbstractTransactionReplicationPacketData

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class AbstractTransactionReplicationPacketData

Throws:

IOException

ClassNotFoundException

getCustomToString

protected String getCustomToString()

Overrides:

getCustomToString in class AbstractTransactionReplicationPacketData

requiresRecoveryFiltering

public boolean requiresRecoveryFiltering()

getRecoveryFilteringId

public Object getRecoveryFilteringId()

Specified by:

getRecoveryFilteringId in interface IReplicationPacketData<IReplicationTransactionalPacketEntryData>

Overrides:

getRecoveryFilteringId in class AbstractTransactionReplicationPacketData

isMultiParticipantData

public boolean isMultiParticipantData()

Description copied from interface: IReplicationPacketData

Gets whether this data is part of multiple participants data