public class StateReceiverImpl<K,V> extends Object implements StateReceiver<K,V>
Constructor and Description |
---|
StateReceiverImpl() |
Modifier and Type | Method and Description |
---|---|
void |
cancelRequests()
Cancels all ongoing replica requests.
|
CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> |
getAllReplicasForSegment(int segmentId,
LocalizedCacheTopology topology,
long timeout)
Return all replicas of a cache entry for a given segment.
|
void |
onDataRehash(DataRehashedEvent<K,V> dataRehashedEvent) |
void |
receiveState(Address sender,
int topologyId,
Collection<StateChunk> stateChunks) |
void |
start() |
void |
stop() |
public void start()
public void stop()
public void cancelRequests()
StateReceiver
cancelRequests
in interface StateReceiver<K,V>
public void onDataRehash(DataRehashedEvent<K,V> dataRehashedEvent)
public CompletableFuture<List<Map<Address,CacheEntry<K,V>>>> getAllReplicasForSegment(int segmentId, LocalizedCacheTopology topology, long timeout)
StateReceiver
getAllReplicasForSegment
in interface StateReceiver<K,V>
public void receiveState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
receiveState
in interface StateReceiver<K,V>
Copyright © 2021 JBoss by Red Hat. All rights reserved.