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

Class ActiveActiveSpaceReplicationEntryEventHandler

java.lang.Object

com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

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

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

All Implemented Interfaces:

IReplicationInEntryHandler, IReplicationInEvictEntryHandler

public class ActiveActiveSpaceReplicationEntryEventHandler
extends AbstractSpaceReplicationEntryEventHandler

Field Summary

Fields inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

_engine, _exceptionHandler

Constructor Summary

Constructors

Constructor	Description
ActiveActiveSpaceReplicationEntryEventHandler(SpaceEngine engine, boolean isCentralAndExternalDB)

Method Summary

Modifier and Type	Method	Description
protected boolean	shouldChangeEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, String typeName, String uid, boolean isTransient, int version)
protected boolean	shouldEvictEntryFromSpace(boolean isTransient)
protected boolean	shouldRemoveEntryFromSpace(boolean isTransient)
protected boolean	shouldUpdateEntryInSpace(IReplicationInContext context, Transaction txn, boolean twoPhaseCommit, IEntryPacket entry)
protected ExtendedAnswerHolder	updateOrWrite(IReplicationInContext context, Transaction transaction, IEntryPacket entryPacket, long lease, int updateModifiers)

Methods inherited from class com.gigaspaces.internal.cluster.node.impl.handlers.AbstractSpaceReplicationEntryEventHandler

changeEntry, changeEntryInSpace, executeUpdateOperation, getConflictingOperationPolicy, ignoreOperation, inEvictEntry, postChangeExecution, postRemoveExecution, postUpdateExecution, removeEntry, removeEntryByUid, removeEntryFromSpace, updateEntry, updateEntryInSpace, writeEntry, writeEntryIntoSpace

Methods inherited from class com.gigaspaces.internal.cluster.node.handlers.AbstractReplicationEntryEventHandler

afterConsumption, beforeConsume, inChangeEntry, inRemoveEntry, inRemoveEntryByUID, inUpdateEntry, inWriteEntry

Methods inherited from class java.lang.Object

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

Constructor Details

ActiveActiveSpaceReplicationEntryEventHandler

public ActiveActiveSpaceReplicationEntryEventHandler(SpaceEngine engine,
 boolean isCentralAndExternalDB)

Method Details

updateOrWrite

protected ExtendedAnswerHolder updateOrWrite(IReplicationInContext context,
 Transaction transaction,
 IEntryPacket entryPacket,
 long lease,
 int updateModifiers)
                                      throws TransactionException,
UnusableEntryException,
UnknownTypeException,
RemoteException,
InterruptedException

Specified by:

updateOrWrite in class AbstractSpaceReplicationEntryEventHandler

Throws:

TransactionException

UnusableEntryException

UnknownTypeException

RemoteException

InterruptedException

shouldUpdateEntryInSpace

protected boolean shouldUpdateEntryInSpace(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 IEntryPacket entry)
                                    throws Exception

Specified by:

shouldUpdateEntryInSpace in class AbstractSpaceReplicationEntryEventHandler

Throws:

Exception

shouldChangeEntryInSpace

protected boolean shouldChangeEntryInSpace(IReplicationInContext context,
 Transaction txn,
 boolean twoPhaseCommit,
 String typeName,
 String uid,
 boolean isTransient,
 int version)
                                    throws Exception

Specified by:

shouldChangeEntryInSpace in class AbstractSpaceReplicationEntryEventHandler

Throws:

Exception

shouldRemoveEntryFromSpace

protected boolean shouldRemoveEntryFromSpace(boolean isTransient)

Specified by:

shouldRemoveEntryFromSpace in class AbstractSpaceReplicationEntryEventHandler

shouldEvictEntryFromSpace

protected boolean shouldEvictEntryFromSpace(boolean isTransient)

Specified by:

shouldEvictEntryFromSpace in class AbstractSpaceReplicationEntryEventHandler