|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.infinispan.statetransfer.StateConsumerImpl
public class StateConsumerImpl
StateConsumer
implementation.
Constructor Summary | |
---|---|
StateConsumerImpl()
|
Method Summary | |
---|---|
void |
addUpdatedKey(Object key)
Receive notification of updated keys right before they are committed in DataContainer. |
void |
applyState(Address sender,
int topologyId,
Collection<StateChunk> stateChunks)
|
CacheTopology |
getCacheTopology()
|
boolean |
hasActiveTransfers()
|
void |
init(Cache cache,
ExecutorService executorService,
StateTransferManager stateTransferManager,
InterceptorChain interceptorChain,
InvocationContextContainer icc,
Configuration configuration,
RpcManager rpcManager,
TransactionManager transactionManager,
CommandsFactory commandsFactory,
CacheLoaderManager cacheLoaderManager,
DataContainer dataContainer,
TransactionTable transactionTable,
StateTransferLock stateTransferLock,
CacheNotifier cacheNotifier)
|
boolean |
isKeyUpdated(Object key)
Checks if a given key was updated by user code during state transfer (and consequently it is untouchable by state transfer). |
boolean |
isStateTransferInProgress()
|
boolean |
isStateTransferInProgressForKey(Object key)
|
void |
onTopologyUpdate(CacheTopology cacheTopology,
boolean isRebalance)
Receive notification of topology changes. |
void |
start()
|
void |
stop()
Cancels all incoming state transfers. |
void |
stopApplyingState()
Stops applying incoming state. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public StateConsumerImpl()
Method Detail |
---|
public void stopApplyingState()
stopApplyingState
in interface StateConsumer
public void addUpdatedKey(Object key)
addUpdatedKey
in interface StateConsumer
key
- the key that is being modifiedpublic boolean isKeyUpdated(Object key)
isKeyUpdated
in interface StateConsumer
key
- the key to check
public void init(Cache cache, ExecutorService executorService, StateTransferManager stateTransferManager, InterceptorChain interceptorChain, InvocationContextContainer icc, Configuration configuration, RpcManager rpcManager, TransactionManager transactionManager, CommandsFactory commandsFactory, CacheLoaderManager cacheLoaderManager, DataContainer dataContainer, TransactionTable transactionTable, StateTransferLock stateTransferLock, CacheNotifier cacheNotifier)
public boolean hasActiveTransfers()
public boolean isStateTransferInProgress()
isStateTransferInProgress
in interface StateConsumer
public boolean isStateTransferInProgressForKey(Object key)
isStateTransferInProgressForKey
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
|
Infinispan Distribution 5.2.6.Final-redhat-2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |