Package com.gigaspaces.internal.server.space.events

Class NotifyBackupLog

java.lang.Object

com.gigaspaces.internal.server.space.events.NotifyBackupLog

All Implemented Interfaces:

IReplicationInNotificationSentHandler

public class NotifyBackupLog
extends Object
implements IReplicationInNotificationSentHandler

Holds a log of all the notifications that were received via replication from the primary. Notifications are held until client receives them.

Since:

7.0

Author:

anna

Constructor Summary

Constructors

Constructor	Description
NotifyBackupLog(WorkingGroup<RemoteEventBusPacket> dataEventDispatcher)

Method Summary

Modifier and Type	Method	Description
void	add(RemoteEventBusPacket packet)	Stored notify events that were generated by replication only on backup
void	clear()	Clear the backup log - called when space becomes primary
void	clearTriggered(OperationID operationId)	Check if all notifications were received and clear them
void	inNotificationSent(IReplicationInContext context, OperationID operationId)
void	processOutgoingEvents()

Methods inherited from class java.lang.Object

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

Constructor Details

NotifyBackupLog

public NotifyBackupLog(WorkingGroup<RemoteEventBusPacket> dataEventDispatcher)

Method Details

add

public void add(RemoteEventBusPacket packet)

Stored notify events that were generated by replication only on backup

clearTriggered

public void clearTriggered(OperationID operationId)

Check if all notifications were received and clear them

clear

public void clear()

Clear the backup log - called when space becomes primary

inNotificationSent

public void inNotificationSent(IReplicationInContext context,
 OperationID operationId)
                        throws RemoteException

Specified by:

inNotificationSent in interface IReplicationInNotificationSentHandler

Throws:

RemoteException

processOutgoingEvents

public void processOutgoingEvents()