com.gigaspaces.internal.cluster.node.impl.handlers

Class SpaceReplicationTransactionEventHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.handlers.SpaceReplicationTransactionEventHandler

All Implemented Interfaces:

IReplicationInTransactionHandler, ITransactionalExecutionCallback

Direct Known Subclasses:

LocalViewReplicationTransactionEventHandler

public class SpaceReplicationTransactionEventHandler
extends Object
implements IReplicationInTransactionHandler, ITransactionalExecutionCallback

Constructor Summary

Constructors

Constructor and Description
SpaceReplicationTransactionEventHandler(SpaceEngine spaceEngine, AbstractReplicationEntryEventHandler entryHandler)

Method Summary

Modifier and Type	Method and Description
void	changeEntry(IReplicationInContext context, Transaction transaction, boolean twoPhaseCommit, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID, IEntryData previousEntryData)
void	inTransaction(IReplicationInContext context, ITransactionInContext transactionContext) Handles one phase commit transaction (single participant)
void	inTransactionAbort(IReplicationInContext context, ITransactionInContext transactionContext) Handle abort stage of two phase committed transaction
void	inTransactionCommit(IReplicationInContext context, ITransactionInContext transactionContext) Handle commit stage of two phase committed transaction
void	inTransactionPrepare(IReplicationInContext context, ITransactionInContext transactionContext) Handle prepare stage of two phase committed transaction
void	removeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
void	removeEntryByUID(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String uid, boolean isTransient, OperationID operationID)
void	updateEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry, IEntryPacket previousEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	writeEntry(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SpaceReplicationTransactionEventHandler

public SpaceReplicationTransactionEventHandler(SpaceEngine spaceEngine,
                                               AbstractReplicationEntryEventHandler entryHandler)

Method Detail

inTransaction

public void inTransaction(IReplicationInContext context,
                          ITransactionInContext transactionContext)
                   throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handles one phase commit transaction (single participant)

Specified by:

inTransaction in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionPrepare

public void inTransactionPrepare(IReplicationInContext context,
                                 ITransactionInContext transactionContext)
                          throws Exception

Description copied from interface: IReplicationInTransactionHandler

Handle prepare stage of two phase committed transaction

Specified by:

inTransactionPrepare in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionCommit

public void inTransactionCommit(IReplicationInContext context,
                                ITransactionInContext transactionContext)
                         throws UnknownTransactionException,
                                RemoteException

Description copied from interface: IReplicationInTransactionHandler

Handle commit stage of two phase committed transaction

Specified by:

inTransactionCommit in interface IReplicationInTransactionHandler

Throws:

UnknownTransactionException

RemoteException

inTransactionAbort

public void inTransactionAbort(IReplicationInContext context,
                               ITransactionInContext transactionContext)

Description copied from interface: IReplicationInTransactionHandler

Handle abort stage of two phase committed transaction

Specified by:

inTransactionAbort in interface IReplicationInTransactionHandler

writeEntry

public void writeEntry(IReplicationInContext context,
                       Transaction txn,
                       boolean twoPhaseCommit,
                       IEntryPacket entry)
                throws Exception

Specified by:

writeEntry in interface ITransactionalExecutionCallback

Throws:

Exception

updateEntry

public void updateEntry(IReplicationInContext context,
                        Transaction txn,
                        boolean twoPhaseCommit,
                        IEntryPacket entry,
                        IEntryPacket previousEntryPacket,
                        boolean partialUpdate,
                        boolean overrideVersion,
                        short flags)
                 throws Exception

Specified by:

updateEntry in interface ITransactionalExecutionCallback

Throws:

Exception

changeEntry

public void changeEntry(IReplicationInContext context,
                        Transaction transaction,
                        boolean twoPhaseCommit,
                        String typeName,
                        String uid,
                        Object id,
                        int version,
                        int previousVersion,
                        long timeToLive,
                        int routingHash,
                        Collection<SpaceEntryMutator> spaceEntryMutators,
                        boolean isTransient,
                        OperationID operationID,
                        IEntryData previousEntryData)
                 throws Exception

Specified by:

changeEntry in interface ITransactionalExecutionCallback

Throws:

Exception

removeEntry

public void removeEntry(IReplicationInContext context,
                        Transaction txn,
                        boolean twoPhaseCommit,
                        IEntryPacket entry)
                 throws Exception

Specified by:

removeEntry in interface ITransactionalExecutionCallback

Throws:

Exception

removeEntryByUID

public void removeEntryByUID(IReplicationInContext context,
                             Transaction txn,
                             boolean twoPhaseCommit,
                             String uid,
                             boolean isTransient,
                             OperationID operationID)
                      throws Exception

Specified by:

removeEntryByUID in interface ITransactionalExecutionCallback

Throws:

Exception