public class BatchingClusterEventManagerImpl<K,V> extends Object implements ClusterEventManager<K,V>
Modifier and Type | Class and Description |
---|---|
protected static class |
BatchingClusterEventManagerImpl.UnicastEventContext<K,V> |
Constructor and Description |
---|
BatchingClusterEventManagerImpl(Cache<K,V> cache) |
Modifier and Type | Method and Description |
---|---|
void |
addEvents(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()
Drops and ignores all previously added events on this thread.
|
void |
sendEvents()
Sends all previously added events on this thread
|
void |
start() |
public void start()
public void addEvents(Address target, UUID identifier, Collection<ClusterEvent<K,V>> events, boolean sync)
ClusterEventManager
ClusterEventManager.sendEvents()
is invoked.
These events are gathered on a per thread basis and batched to reduce number of RPCs required.addEvents
in interface ClusterEventManager<K,V>
target
- 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 notpublic void sendEvents()
ClusterEventManager
sendEvents
in interface ClusterEventManager<K,V>
public void dropEvents()
ClusterEventManager
dropEvents
in interface ClusterEventManager<K,V>
Copyright © 2024 JBoss, a division of Red Hat. All rights reserved.