public class StateConsumerImpl extends Object implements StateConsumer
StateConsumer
implementation.Modifier and Type | Class and Description |
---|---|
static interface |
StateConsumerImpl.KeyInvalidationListener |
Constructor and Description |
---|
StateConsumerImpl() |
Modifier and Type | Method and Description |
---|---|
void |
applyState(Address sender,
int topologyId,
Collection<StateChunk> stateChunks) |
CacheTopology |
getCacheTopology() |
boolean |
hasActiveTransfers() |
void |
init(Cache cache,
ExecutorService stateTransferExecutor,
StateTransferManager stateTransferManager,
InterceptorChain interceptorChain,
InvocationContextFactory icf,
Configuration configuration,
RpcManager rpcManager,
TransactionManager transactionManager,
CommandsFactory commandsFactory,
PersistenceManager persistenceManager,
DataContainer<Object,Object> dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier,
TotalOrderManager totalOrderManager,
BlockingTaskAwareExecutorService remoteCommandsExecutor,
CommitManager commitManager) |
boolean |
isStateTransferInProgress() |
boolean |
isStateTransferInProgressForKey(Object key) |
void |
onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes.
|
boolean |
ownsData() |
void |
setKeyInvalidationListener(StateConsumerImpl.KeyInvalidationListener keyInvalidationListener) |
void |
start() |
void |
stop()
Cancels all incoming state transfers.
|
void |
stopApplyingState()
Stops applying incoming state.
|
public void stopApplyingState()
stopApplyingState
in interface StateConsumer
public void init(Cache cache, ExecutorService stateTransferExecutor, StateTransferManager stateTransferManager, InterceptorChain interceptorChain, InvocationContextFactory icf, Configuration configuration, RpcManager rpcManager, TransactionManager transactionManager, CommandsFactory commandsFactory, PersistenceManager persistenceManager, DataContainer<Object,Object> dataContainer, TransactionTable transactionTable, StateTransferLock stateTransferLock, CacheNotifier cacheNotifier, TotalOrderManager totalOrderManager, BlockingTaskAwareExecutorService remoteCommandsExecutor, CommitManager commitManager)
public boolean hasActiveTransfers()
public boolean isStateTransferInProgress()
isStateTransferInProgress
in interface StateConsumer
public boolean isStateTransferInProgressForKey(Object key)
isStateTransferInProgressForKey
in interface StateConsumer
public boolean ownsData()
ownsData
in interface StateConsumer
public void onTopologyUpdate(CacheTopology cacheTopology, boolean isRebalance)
StateConsumer
onTopologyUpdate
in interface StateConsumer
public void applyState(Address sender, int topologyId, Collection<StateChunk> stateChunks)
applyState
in interface StateConsumer
public void start()
public void stop()
StateConsumer
stop
in interface StateConsumer
public CacheTopology getCacheTopology()
getCacheTopology
in interface StateConsumer
public void setKeyInvalidationListener(StateConsumerImpl.KeyInvalidationListener keyInvalidationListener)
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.