public class NonTotalOrderPerCacheInboundInvocationHandler extends BasePerCacheInboundInvocationHandler implements LockListener
PerCacheInboundInvocationHandler
implementation for non-total order
caches.NO_TOPOLOGY_COMMAND, remoteCommandsExecutor, stateTransferLock, stateTransferManager
Constructor and Description |
---|
NonTotalOrderPerCacheInboundInvocationHandler() |
Modifier and Type | Method and Description |
---|---|
protected Log |
getLog() |
void |
handle(CacheRpcCommand command,
Reply reply,
DeliverOrder order)
Handles the
CacheRpcCommand from other node. |
void |
inject(LockManager lockManager,
ClusteringDependentLogic clusteringDependentLogic,
Configuration configuration) |
protected boolean |
isTraceEnabled() |
void |
onEvent(LockState state)
Invoked when the lock is available.
|
createDefaultRunnable, executeOnExecutorService, extractCommandTopologyId, handleRunnable, injectDependencies, isCommandSentBeforeFirstTopology, unexpectedDeliverMode
public NonTotalOrderPerCacheInboundInvocationHandler()
public void inject(LockManager lockManager, ClusteringDependentLogic clusteringDependentLogic, Configuration configuration)
public void handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
PerCacheInboundInvocationHandler
CacheRpcCommand
from other node.handle
in interface PerCacheInboundInvocationHandler
command
- the CacheRpcCommand
to handle-reply
- the return value is passed to this object in order to be sent back to the senderorder
- the DeliverOrder
in which the command was sentpublic void onEvent(LockState state)
LockListener
onEvent
in interface LockListener
state
- the lock state. Possible values are LockState.ACQUIRED
, LockState.TIMED_OUT
or
LockState.DEADLOCKED
.protected Log getLog()
getLog
in class BasePerCacheInboundInvocationHandler
protected boolean isTraceEnabled()
isTraceEnabled
in class BasePerCacheInboundInvocationHandler
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.