org.infinispan.notifications.cachelistener.cluster.impl

Class ClusterEventManagerStub<K,V>

java.lang.Object

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

All Implemented Interfaces:

ClusterEventManager<K,V>

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

Author:

Radim Vansa <rvansa@redhat.com>

Constructor Summary

Constructors

Constructor and Description
ClusterEventManagerStub()

Method Summary

Modifier and Type	Method and Description
void	addEvents(Address target, UUID identifier, Collection<ClusterEvent<K,V>> clusterEvents, 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

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterEventManagerStub

public ClusterEventManagerStub()

Method Detail

addEvents

public void addEvents(Address target,
                      UUID identifier,
                      Collection<ClusterEvent<K,V>> clusterEvents,
                      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

clusterEvents - The events that were generated

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

sendEvents

public void sendEvents()
                throws CacheException

Description copied from interface: ClusterEventManager

Sends all previously added events on this thread

Specified by:

sendEvents in interface ClusterEventManager<K,V>

Throws:

CacheException

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>