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 Description ClusterEventManagerStub()
-
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>> 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
-
-
-
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 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 eventsclusterEvents
- 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>
-
-