Interface ClusterEventManager<K,V>
- All Known Implementing Classes:
BatchingClusterEventManagerImpl
,ClusterEventManagerStub
public interface ClusterEventManager<K,V>
-
Method Summary
Modifier and TypeMethodDescriptionvoid
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.sendEvents
(Object batchIdentifier) Sends all previously added events for the given identifier
-
Method Details
-
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 thebatchIdentifier
pending their submission whensendEvents(Object)
is invoked or cancelled whendropEvents(Object)
is invoked.- 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
Sends all previously added events for the given identifier -
dropEvents
Drops and ignores all previously added events for the given identifier.
-