com.gigaspaces.internal.cluster.node.impl.gateway.sink

Class LocalClusterReplicationInTransactionHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationInTransactionHandler

All Implemented Interfaces:

IReplicationInTransactionHandler, ITransactionalBatchExecutionCallback

public class LocalClusterReplicationInTransactionHandler
extends AbstractLocalClusterReplicationInHandler
implements IReplicationInTransactionHandler, ITransactionalBatchExecutionCallback

A handler for a transactional set of operations replicated to a gateway sink component.

Since:

8.0.3

Author:

idan

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

_config, _spaceProxy

Constructor Summary

Constructors

Constructor and Description
LocalClusterReplicationInTransactionHandler(ISpaceProxy spaceProxy, ITransactionManagerProvider transactionManagerProvider, LocalClusterReplicationSinkConfig config)

Method Summary

Modifier and Type	Method and Description
void	changeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, int previousVersion, long timeToLive, int routingHash, Collection<SpaceEntryMutator> spaceEntryMutators, boolean isTransient, OperationID operationID)
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(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	removeEntryByUID(IReplicationInBatchContext context, String typeName, String uid, OperationID operationID)
void	updateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, short flags)
void	writeEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.gateway.sink.AbstractLocalClusterReplicationInHandler

execute, executeIfUidPresent, executeTransactional, extractSourceGatewayName, getSpaceProxy, handleChangeEntry, handleRemoveEntry, handleRemoveEntryByUid, handleUpdateEntry, handleWriteEntry, invokeConflictResolver

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalClusterReplicationInTransactionHandler

public LocalClusterReplicationInTransactionHandler(ISpaceProxy spaceProxy,
                                                   ITransactionManagerProvider transactionManagerProvider,
                                                   LocalClusterReplicationSinkConfig config)

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 Exception

Description copied from interface: IReplicationInTransactionHandler

Handle commit stage of two phase committed transaction

Specified by:

inTransactionCommit in interface IReplicationInTransactionHandler

Throws:

Exception

inTransactionAbort

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

Description copied from interface: IReplicationInTransactionHandler

Handle abort stage of two phase committed transaction

Specified by:

inTransactionAbort in interface IReplicationInTransactionHandler

Throws:

Exception

writeEntry

public void writeEntry(IReplicationInBatchContext context,
                       IEntryPacket entryPacket)
                throws Exception

Specified by:

writeEntry in interface ITransactionalBatchExecutionCallback

Throws:

Exception

removeEntry

public void removeEntry(IReplicationInBatchContext context,
                        IEntryPacket entryPacket)
                 throws Exception

Specified by:

removeEntry in interface ITransactionalBatchExecutionCallback

Throws:

Exception

removeEntryByUID

public void removeEntryByUID(IReplicationInBatchContext context,
                             String typeName,
                             String uid,
                             OperationID operationID)
                      throws Exception

Specified by:

removeEntryByUID in interface ITransactionalBatchExecutionCallback

Throws:

Exception

updateEntry

public void updateEntry(IReplicationInBatchContext context,
                        IEntryPacket entryPacket,
                        IEntryPacket oldEntryPacket,
                        boolean partialUpdate,
                        short flags)
                 throws Exception

Specified by:

updateEntry in interface ITransactionalBatchExecutionCallback

Throws:

Exception

changeEntry

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

Specified by:

changeEntry in interface ITransactionalBatchExecutionCallback

Throws:

Exception