org.infinispan.notifications.cachelistener.cluster.impl

Class BatchingClusterEventManagerImpl<K,V>

java.lang.Object

org.infinispan.notifications.cachelistener.cluster.impl.BatchingClusterEventManagerImpl<K,V>

All Implemented Interfaces:

ClusterEventManager<K,V>

public class BatchingClusterEventManagerImpl<K,V>
extends Object
implements ClusterEventManager<K,V>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BatchingClusterEventManagerImpl.UnicastEventContext<K,V>

Constructor Summary

Constructors

Constructor and Description
BatchingClusterEventManagerImpl(Cache<K,V> cache)

Method Summary

Modifier and Type	Method and 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
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchingClusterEventManagerImpl

public BatchingClusterEventManagerImpl(Cache<K,V> cache)

Method Detail

start

public void start()

addEvents

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

Description copied from interface: ClusterEventManager

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 ClusterEventManager.sendEvents() is invoked. These events are gathered on a per thread basis and batched to reduce number of RPCs required.

Specified by:

addEvents in interface ClusterEventManager<K,V>

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

public void sendEvents()

Description copied from interface: ClusterEventManager

Sends all previously added events on this thread

Specified by:

sendEvents in interface ClusterEventManager<K,V>

dropEvents

public void dropEvents()

Description copied from interface: ClusterEventManager

Drops and ignores all previously added events on this thread.

Specified by:

dropEvents in interface ClusterEventManager<K,V>