Package com.gigaspaces.internal.events.durable

Class ReplicationNotificationInEntryHandler

java.lang.Object

com.gigaspaces.internal.events.durable.AbstractReplicationNotificationInEntryHandler

com.gigaspaces.internal.events.durable.ReplicationNotificationInEntryHandler

All Implemented Interfaces:

IReplicationInEntryHandler, IReplicationInEntryLeaseExpiredHandler

public class ReplicationNotificationInEntryHandler
extends AbstractReplicationNotificationInEntryHandler

Since:

9.0

Author:

Dan Kilman

Field Summary

Fields inherited from class com.gigaspaces.internal.events.durable.AbstractReplicationNotificationInEntryHandler

_eventID, _listener, _notifyInfo, _notifyType, _remoteSpace, _sequenceNumber

Constructor Summary

Constructors

Constructor	Description
ReplicationNotificationInEntryHandler(NotifyInfo notifyInfo, IDirectSpaceProxy remoteSpace, long eventID, ITemplatePacket templatePacket, ReplicationNotificationClientEndpoint endpoint)

Method Summary

Modifier and Type	Method	Description
protected void	handleEntryImpl(EntryArrivedRemoteEvent entryArrived, IReplicationInContext context, boolean inTransaction)

Methods inherited from class com.gigaspaces.internal.events.durable.AbstractReplicationNotificationInEntryHandler

afterConsumption, beforeConsume, consumeBatchContentIfNotInTransaction, createEntryArrivedRemoteEvent, handleEntryLeaseExpired, handleEntryLeaseExpiredByUID, handleRemoveEntry, handleRemoveEntryByUID, handleUpdateEntry, handleWriteEntry, inChangeEntry, inEntryLeaseExpired, inEntryLeaseExpiredByUID, inRemoveEntry, inRemoveEntryByUID, inUpdateEntry, inWriteEntry

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicationNotificationInEntryHandler

public ReplicationNotificationInEntryHandler(NotifyInfo notifyInfo,
 IDirectSpaceProxy remoteSpace,
 long eventID,
 ITemplatePacket templatePacket,
 ReplicationNotificationClientEndpoint endpoint)

Method Details

handleEntryImpl

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

Specified by:

handleEntryImpl in class AbstractReplicationNotificationInEntryHandler