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(Object batchIdentifier, 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(Object batchIdentifier) Drops and ignores all previously added events for the given identifier.
CompletionStage<Void>	sendEvents(Object batchIdentifier) Sends all previously added events for the given identifier

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(Object batchIdentifier,
                      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 batched by the batchIdentifier pending their submission when ClusterEventManager.sendEvents(Object) is invoked or cancelled when ClusterEventManager.dropEvents(Object) is invoked.

Specified by:

addEvents in interface ClusterEventManager<K,V>

Parameters:

batchIdentifier - identifier for the batch

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 CompletionStage<Void> sendEvents(Object batchIdentifier)

Description copied from interface: ClusterEventManager

Sends all previously added events for the given identifier

Specified by:

sendEvents in interface ClusterEventManager<K,V>

dropEvents

public void dropEvents(Object batchIdentifier)

Description copied from interface: ClusterEventManager

Drops and ignores all previously added events for the given identifier.

Specified by:

dropEvents in interface ClusterEventManager<K,V>