Class NonTotalOrderPerCacheInboundInvocationHandler
- java.lang.Object
-
- org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler
-
- org.infinispan.remoting.inboundhandler.NonTotalOrderPerCacheInboundInvocationHandler
-
- All Implemented Interfaces:
PerCacheInboundInvocationHandler
,LockListener
public class NonTotalOrderPerCacheInboundInvocationHandler extends BasePerCacheInboundInvocationHandler implements LockListener
APerCacheInboundInvocationHandler
implementation for non-total order caches.- Since:
- 7.1
- Author:
- Pedro Ruivo
-
-
Field Summary
-
Fields inherited from class org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler
configuration, remoteCommandsExecutor, stateTransferManager
-
-
Constructor Summary
Constructors Constructor Description NonTotalOrderPerCacheInboundInvocationHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected Log
getLog()
void
handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
Handles theCacheRpcCommand
from other node.protected boolean
isTraceEnabled()
void
onEvent(LockState state)
Invoked when the lock is available.void
start()
-
Methods inherited from class org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler
isCommandSentBeforeFirstTopology, isStopped, stop
-
-
-
-
Method Detail
-
start
public void start()
-
handle
public void handle(CacheRpcCommand command, Reply reply, DeliverOrder order)
Description copied from interface:PerCacheInboundInvocationHandler
Handles theCacheRpcCommand
from other node.- Specified by:
handle
in interfacePerCacheInboundInvocationHandler
- Parameters:
command
- theCacheRpcCommand
to handle-reply
- the return value is passed to this object in order to be sent back to the senderorder
- theDeliverOrder
in which the command was sent
-
onEvent
public void onEvent(LockState state)
Description copied from interface:LockListener
Invoked when the lock is available.- Specified by:
onEvent
in interfaceLockListener
- Parameters:
state
- the lock state. Possible values areLockState.ACQUIRED
,LockState.TIMED_OUT
orLockState.DEADLOCKED
.
-
getLog
protected Log getLog()
- Specified by:
getLog
in classBasePerCacheInboundInvocationHandler
-
isTraceEnabled
protected boolean isTraceEnabled()
- Specified by:
isTraceEnabled
in classBasePerCacheInboundInvocationHandler
-
-