Package org.infinispan.notifications.cachelistener.cluster

Interface ClusterEventManager<K,V>

public interface ClusterEventManager<K,V>

Method Summary

Modifier and Type	Method	Description
void	addEvents(Address target, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)	Adds additional cluster events that need to be sent remotely for an event originating locally.
void	dropEvents()	Drops and ignores all previously added events on this thread.
void	sendEvents()	Sends all previously added events on this thread

Method Detail

addEvents

void addEvents(Address target,
               UUID identifier,
               Collection<ClusterEvent<K,V>> events,
               boolean sync)

Adds additional cluster events that need to be sent remotely for an event originating locally. These events are not sent at time of registering but rather after the sendEvents() is invoked. These events are gathered on a per thread basis and batched to reduce number of RPCs required.

Parameters:

target - The target node this event was meant for

identifier - The cluster listener that is identified for these events

events - The events that were generated

sync - Whether these events need to be sent synchronously or not

sendEvents

void sendEvents()
         throws CacheException

Sends all previously added events on this thread

Throws:

CacheException

dropEvents

void dropEvents()

Drops and ignores all previously added events on this thread.