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

Class SpaceDataEventManager

java.lang.Object

com.gigaspaces.internal.server.space.events.SpaceDataEventManager

All Implemented Interfaces:

ISpaceModeListener, Remote, EventListener

public class SpaceDataEventManager
extends Object
implements ISpaceModeListener

Control NotifyStatus status. This controller calls a given NotifyStatus for each notification trigger/return.

Since:

6.0

Version:

1.0

Author:

Guy korland

Constructor Summary

Constructors

Constructor	Description
SpaceDataEventManager(IDirectSpaceProxy spaceProxy, FilterManager filterManager, SpaceImpl spaceImpl, SpaceConfigReader configReader)

Method Summary

Modifier and Type	Method	Description
void	afterSpaceModeChange(SpaceMode newMode)	Called right after the space mode changes.
void	beforeSpaceModeChange(SpaceMode newMode)	Called right before the space mode changes. Implementors usually use it to allow specific service initializations.
void	close()
void	executePacket(RemoteEventBusPacket re, NotifyTemplateHolder th)
void	finishTemplatesSearch(NotifyContext notifyContext)	Called when the matching search is over
long	generateEventId()
int	getQueueSize()
void	init(boolean isReplicated, IReplicationNode replicationNode)
void	notifyReturned(NotifyContext notifyContext, ITemplateHolder template)	Called when a notification returned
void	notifyTemplate(NotifyTemplateHolder template, IEntryHolder entry, IEntryHolder oldEntry, NotifyContext notifyContext, Context ctx)	Notifies a notification template with the specified remote event Notification is done asynchronously, by sending a bus packet to the Notifier.
void	setLeaseManager(LeaseManager leaseManager)

Methods inherited from class java.lang.Object

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

Constructor Details

SpaceDataEventManager

public SpaceDataEventManager(IDirectSpaceProxy spaceProxy,
 FilterManager filterManager,
 SpaceImpl spaceImpl,
 SpaceConfigReader configReader)

Method Details

init

public void init(boolean isReplicated,
 IReplicationNode replicationNode)

setLeaseManager

public void setLeaseManager(LeaseManager leaseManager)

close

public void close()

notifyReturned

public void notifyReturned(NotifyContext notifyContext,
 ITemplateHolder template)

Called when a notification returned

Parameters:

notifyContext - current notify status checked

template - the current template to filter

finishTemplatesSearch

public void finishTemplatesSearch(NotifyContext notifyContext)

Called when the matching search is over

Parameters:

notifyContext - current notify status checked

template - the current template to filter

afterSpaceModeChange

public void afterSpaceModeChange(SpaceMode newMode)
                          throws RemoteException

Description copied from interface: ISpaceModeListener

Called right after the space mode changes.
Implementors usually use it to invoke any needed services.

Specified by:

afterSpaceModeChange in interface ISpaceModeListener

Parameters:

newMode - the new mode change after it was published.

Throws:

RemoteException - if an exception occurred during execution of a remote call.

beforeSpaceModeChange

public void beforeSpaceModeChange(SpaceMode newMode)
                           throws RemoteException

Description copied from interface: ISpaceModeListener

Called right before the space mode changes.
Implementors usually use it to allow specific service initializations.

Specified by:

beforeSpaceModeChange in interface ISpaceModeListener

Parameters:

newMode - the new mode change before it's published.

Throws:

RemoteException - if an exception occurred during execution of a remote call.

generateEventId

public long generateEventId()

getQueueSize

public int getQueueSize()

executePacket

public void executePacket(RemoteEventBusPacket re,
 NotifyTemplateHolder th)
                   throws RemoteException,
UnknownEventException

Throws:

RemoteException

UnknownEventException

notifyTemplate

public void notifyTemplate(NotifyTemplateHolder template,
 IEntryHolder entry,
 IEntryHolder oldEntry,
 NotifyContext notifyContext,
 Context ctx)

Notifies a notification template with the specified remote event Notification is done asynchronously, by sending a bus packet to the Notifier. Assumes template is locked.