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 Description protected class
BatchingClusterEventManagerImpl.UnicastEventContext<K,V>
-
Constructor Summary
Constructors Constructor Description BatchingClusterEventManagerImpl()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 identifiervoid
start()
-
-
-
Method Detail
-
start
public void start()
-
addEvents
public void addEvents(Object batchIdentifier, 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 batched by thebatchIdentifier
pending their submission whenClusterEventManager.sendEvents(Object)
is invoked or cancelled whenClusterEventManager.dropEvents(Object)
is invoked.- Specified by:
addEvents
in interfaceClusterEventManager<K,V>
- Parameters:
batchIdentifier
- identifier for the batchtarget
- The target node this event was meant foridentifier
- The cluster listener that is identified for these eventsevents
- The events that were generatedsync
- 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 interfaceClusterEventManager<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 interfaceClusterEventManager<K,V>
-
-