public class ClusterEventManagerStub<K,V> extends Object implements ClusterEventManager<K,V>
Constructor and Description |
---|
ClusterEventManagerStub() |
Modifier and Type | Method and Description |
---|---|
void |
addEvents(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()
Drops and ignores all previously added events on this thread.
|
void |
sendEvents()
Sends all previously added events on this thread
|
public void addEvents(Address target, UUID identifier, Collection<ClusterEvent<K,V>> clusterEvents, 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 eventsclusterEvents
- The events that were generatedsync
- Whether these events need to be sent synchronously or notpublic void sendEvents() throws CacheException
ClusterEventManager
sendEvents
in interface ClusterEventManager<K,V>
CacheException
public void dropEvents()
ClusterEventManager
dropEvents
in interface ClusterEventManager<K,V>
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.