org.infinispan.notifications.cachelistener.cluster

Interface ClusterEventManager<K,V>

All Known Implementing Classes:

BatchingClusterEventManagerImpl, ClusterEventManagerStub

public interface ClusterEventManager<K,V>

Method Summary

Modifier and Type	Method and Description
void	addEvents(Object batchIdentifier, 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(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

Method Detail

addEvents

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

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

events - The events that were generated

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

sendEvents

CompletionStage<Void> sendEvents(Object batchIdentifier)

Sends all previously added events for the given identifier

dropEvents

void dropEvents(Object batchIdentifier)

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