com.gigaspaces.internal.events.durable

Class AbstractReplicationNotificationInEntryHandler

java.lang.Object

com.gigaspaces.internal.events.durable.AbstractReplicationNotificationInEntryHandler

All Implemented Interfaces:

IReplicationInEntryHandler, IReplicationInEntryLeaseExpiredHandler

Direct Known Subclasses:

ReplicationNotificationBatchInEntryHandler, ReplicationNotificationInEntryHandler

public abstract class AbstractReplicationNotificationInEntryHandler
extends Object
implements IReplicationInEntryHandler, IReplicationInEntryLeaseExpiredHandler

Since:

9.0

Author:

Dan Kilman

Field Summary

Fields

Modifier and Type	Field and Description
protected long	_eventID
protected RemoteEventListener	_listener
protected NotifyInfo	_notifyInfo
protected NotifyActionType	_notifyType
protected IDirectSpaceProxy	_remoteSpace
protected AtomicLong	_sequenceNumber

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractReplicationNotificationInEntryHandler(NotifyInfo notifyInfo, IDirectSpaceProxy remoteSpace, long eventID, ITemplatePacket templatePacket)

Method Summary

Modifier and Type	Method and Description
void	afterConsumption(IReplicationInContext context, boolean successful, long lastProcessedKey)
void	beforeConsume(IReplicationInContext context)
protected static void	consumeBatchContentIfNotInTransaction(IReplicationInContext context, boolean inTransaction)
protected EntryArrivedRemoteEvent	createEntryArrivedRemoteEvent(IEntryPacket entryPacket, IEntryPacket oldEntryPacket, NotifyActionType notifyActionType)
protected abstract void	handleEntryImpl(EntryArrivedRemoteEvent entryArrived, IReplicationInContext context, boolean inTransaction)
void	handleEntryLeaseExpired(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket)
void	handleEntryLeaseExpiredByUID(IReplicationInContext context, boolean inTransaction, String className, String uid, boolean isTransient, OperationID operationID)
void	handleRemoveEntry(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket)
void	handleRemoveEntryByUID(IReplicationInContext context, boolean inTransaction, String uid, boolean isTransient, OperationID operationID)
void	handleUpdateEntry(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	handleWriteEntry(IReplicationInContext context, boolean inTransaction, IEntryPacket entryPacket)
void	inChangeEntry(IReplicationInContext context, String typeName, String uid, Object id, int version, int previousVersion, int routingHash, long timeToLive, Collection<SpaceEntryMutator> mutators, boolean isTransient, OperationID operationID)
void	inEntryLeaseExpired(IReplicationInContext context, IEntryPacket entryPacket)
void	inEntryLeaseExpiredByUID(IReplicationInContext context, String className, String uid, boolean isTransient, OperationID operationID)
void	inRemoveEntry(IReplicationInContext context, IEntryPacket entryPacket)
void	inRemoveEntryByUID(IReplicationInContext context, String typeName, String uid, boolean isTransient, OperationID operationID)
void	inUpdateEntry(IReplicationInContext context, IEntryPacket entryPacket, IEntryPacket oldEntryPacket, boolean partialUpdate, boolean overrideVersion, short flags)
void	inWriteEntry(IReplicationInContext context, IEntryPacket entryPacket)

Methods inherited from class java.lang.Object

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

Field Detail

_notifyInfo

protected final NotifyInfo _notifyInfo

_notifyType

protected final NotifyActionType _notifyType

_listener

protected final RemoteEventListener _listener

_remoteSpace

protected final IDirectSpaceProxy _remoteSpace

_sequenceNumber

protected final AtomicLong _sequenceNumber

_eventID

protected final long _eventID

Constructor Detail

AbstractReplicationNotificationInEntryHandler

protected AbstractReplicationNotificationInEntryHandler(NotifyInfo notifyInfo,
                                                        IDirectSpaceProxy remoteSpace,
                                                        long eventID,
                                                        ITemplatePacket templatePacket)

Method Detail

consumeBatchContentIfNotInTransaction

protected static void consumeBatchContentIfNotInTransaction(IReplicationInContext context,
                                                            boolean inTransaction)

handleEntryLeaseExpiredByUID

public void handleEntryLeaseExpiredByUID(IReplicationInContext context,
                                         boolean inTransaction,
                                         String className,
                                         String uid,
                                         boolean isTransient,
                                         OperationID operationID)

handleEntryLeaseExpired

public void handleEntryLeaseExpired(IReplicationInContext context,
                                    boolean inTransaction,
                                    IEntryPacket entryPacket)

handleUpdateEntry

public void handleUpdateEntry(IReplicationInContext context,
                              boolean inTransaction,
                              IEntryPacket entryPacket,
                              IEntryPacket oldEntryPacket,
                              boolean partialUpdate,
                              boolean overrideVersion,
                              short flags)

handleRemoveEntry

public void handleRemoveEntry(IReplicationInContext context,
                              boolean inTransaction,
                              IEntryPacket entryPacket)

handleRemoveEntryByUID

public void handleRemoveEntryByUID(IReplicationInContext context,
                                   boolean inTransaction,
                                   String uid,
                                   boolean isTransient,
                                   OperationID operationID)

handleWriteEntry

public void handleWriteEntry(IReplicationInContext context,
                             boolean inTransaction,
                             IEntryPacket entryPacket)

handleEntryImpl

protected abstract void handleEntryImpl(EntryArrivedRemoteEvent entryArrived,
                                        IReplicationInContext context,
                                        boolean inTransaction)

createEntryArrivedRemoteEvent

protected EntryArrivedRemoteEvent createEntryArrivedRemoteEvent(IEntryPacket entryPacket,
                                                                IEntryPacket oldEntryPacket,
                                                                NotifyActionType notifyActionType)

inEntryLeaseExpiredByUID

public void inEntryLeaseExpiredByUID(IReplicationInContext context,
                                     String className,
                                     String uid,
                                     boolean isTransient,
                                     OperationID operationID)

Specified by:

inEntryLeaseExpiredByUID in interface IReplicationInEntryLeaseExpiredHandler

inEntryLeaseExpired

public void inEntryLeaseExpired(IReplicationInContext context,
                                IEntryPacket entryPacket)

Specified by:

inEntryLeaseExpired in interface IReplicationInEntryLeaseExpiredHandler

inUpdateEntry

public void inUpdateEntry(IReplicationInContext context,
                          IEntryPacket entryPacket,
                          IEntryPacket oldEntryPacket,
                          boolean partialUpdate,
                          boolean overrideVersion,
                          short flags)
                   throws Exception

Specified by:

inUpdateEntry in interface IReplicationInEntryHandler

Throws:

Exception

inRemoveEntry

public void inRemoveEntry(IReplicationInContext context,
                          IEntryPacket entryPacket)
                   throws Exception

Specified by:

inRemoveEntry in interface IReplicationInEntryHandler

Throws:

Exception

inRemoveEntryByUID

public void inRemoveEntryByUID(IReplicationInContext context,
                               String typeName,
                               String uid,
                               boolean isTransient,
                               OperationID operationID)
                        throws Exception

Specified by:

inRemoveEntryByUID in interface IReplicationInEntryHandler

Throws:

Exception

inWriteEntry

public void inWriteEntry(IReplicationInContext context,
                         IEntryPacket entryPacket)
                  throws Exception

Specified by:

inWriteEntry in interface IReplicationInEntryHandler

Throws:

Exception

inChangeEntry

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

Specified by:

inChangeEntry in interface IReplicationInEntryHandler

Throws:

Exception

afterConsumption

public void afterConsumption(IReplicationInContext context,
                             boolean successful,
                             long lastProcessedKey)

Specified by:

afterConsumption in interface IReplicationInEntryHandler

beforeConsume

public void beforeConsume(IReplicationInContext context)

Specified by:

beforeConsume in interface IReplicationInEntryHandler