com.gigaspaces.internal.sync.mirror

Class MirrorReplicationInHandler

java.lang.Object

com.gigaspaces.internal.sync.mirror.MirrorReplicationInHandler

All Implemented Interfaces:

ITransactionalBatchExecutionCallback

Direct Known Subclasses:

MirrorReplicationInAggregatedTransactionHandler, MirrorReplicationInBatchConsumptionHandler, MirrorReplicationInEntryHandler, MirrorReplicationInTransactionHandler, MirrorReplicationMetadataEventHandler

public class MirrorReplicationInHandler
extends Object
implements ITransactionalBatchExecutionCallback

Handles incoming replicated operations on mirror

Since:

8.0

Version:

1.0

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
protected SpaceSynchronizationEndpoint	_syncEndpoint

Constructor Summary

Constructors

Constructor and Description
MirrorReplicationInHandler(MirrorBulkExecutor bulkExecutor, MirrorStatisticsImpl operationStatisticsHandler)

Method Summary

Modifier and Type	Method and Description
void	addChangeEntry(IReplicationInBatchContext context, String typeName, String uid, Object id, int version, long timeToLive, Collection<SpaceEntryMutator> mutators)
void	addRemoveEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
void	addTransaction(IReplicationInBatchContext context, ITransactionInContext transactionContext)
void	addUpdateEntry(IReplicationInBatchContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate)
void	addWriteEntry(IReplicationInBatchContext context, IEntryPacket entryPacket)
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)
protected void	execute(IReplicationInBatchContext batchContext, TransactionParticipantDataImpl transactionParticipantData)
SpaceTypeManager	getTypeManager()
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

Field Detail

_syncEndpoint

protected final SpaceSynchronizationEndpoint _syncEndpoint

Constructor Detail

MirrorReplicationInHandler

public MirrorReplicationInHandler(MirrorBulkExecutor bulkExecutor,
                                  MirrorStatisticsImpl operationStatisticsHandler)

Method Detail

addWriteEntry

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

Throws:

Exception

addUpdateEntry

public void addUpdateEntry(IReplicationInBatchContext context,
                           IEntryPacket entryPacket,
                           IEntryPacket oldEntryPacket,
                           boolean partialUpdate)
                    throws Exception

Throws:

Exception

addRemoveEntry

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

Throws:

Exception

addChangeEntry

public void addChangeEntry(IReplicationInBatchContext context,
                           String typeName,
                           String uid,
                           Object id,
                           int version,
                           long timeToLive,
                           Collection<SpaceEntryMutator> mutators)
                    throws UnknownTypeException

Throws:

UnknownTypeException

addTransaction

public void addTransaction(IReplicationInBatchContext context,
                           ITransactionInContext transactionContext)
                    throws Exception

Throws:

Exception

execute

protected void execute(IReplicationInBatchContext batchContext,
                       TransactionParticipantDataImpl transactionParticipantData)
                throws SAException

Throws:

SAException

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

writeEntry

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

Specified by:

writeEntry in interface ITransactionalBatchExecutionCallback

Throws:

Exception

getTypeManager

public SpaceTypeManager getTypeManager()

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 UnknownTypeException

Specified by:

changeEntry in interface ITransactionalBatchExecutionCallback

Throws:

UnknownTypeException