Package com.gigaspaces.internal.events.durable

Class ReplicationNotificationInTransactionEntryHandler

java.lang.Object

com.gigaspaces.internal.events.durable.ReplicationNotificationInTransactionEntryHandler

All Implemented Interfaces:

IReplicationInTransactionHandler, ITransactionalBatchExecutionCallback

public class ReplicationNotificationInTransactionEntryHandler
extends Object
implements IReplicationInTransactionHandler, ITransactionalBatchExecutionCallback

Since:

9.0

Author:

Dan Kilman

Constructor Summary

Constructors

Constructor	Description
ReplicationNotificationInTransactionEntryHandler(AbstractReplicationNotificationInEntryHandler entryHandler, boolean isBatchMode)

Method Summary

Modifier and Type	Method	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 java.lang.Object

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

Constructor Details

ReplicationNotificationInTransactionEntryHandler

public ReplicationNotificationInTransactionEntryHandler(AbstractReplicationNotificationInEntryHandler entryHandler,
 boolean isBatchMode)

Method Details

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

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

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

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)

Specified by:

changeEntry in interface ITransactionalBatchExecutionCallback