Class NonTotalOrderTxPerCacheInboundInvocationHandler
- java.lang.Object
-
- org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler
-
- org.infinispan.remoting.inboundhandler.NonTotalOrderTxPerCacheInboundInvocationHandler
-
- All Implemented Interfaces:
JmxStatisticsExposer
,PerCacheInboundInvocationHandler
public class NonTotalOrderTxPerCacheInboundInvocationHandler extends BasePerCacheInboundInvocationHandler
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, MBEAN_COMPONENT_NAME, remoteCommandsExecutor
-
-
Constructor Summary
Constructors Constructor Description NonTotalOrderTxPerCacheInboundInvocationHandler()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.infinispan.util.logging.Log
getLog()
void
handle(org.infinispan.commands.remote.CacheRpcCommand command, Reply reply, DeliverOrder order)
Handles theCacheRpcCommand
from other node.protected boolean
isTraceEnabled()
void
start()
-
Methods inherited from class org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler
getAsyncXSitePendingRequests, getAsyncXSiteRequestQueueTime, getAsyncXSiteRequestRunningTime, getAsyncXSiteRequestsReceived, getAsyncXSiteRunningRequests, getFirstTopologyAsMember, getStatisticsEnabled, getSyncXSiteRequestsReceived, isCommandSentBeforeFirstTopology, isStatisticsEnabled, isStopped, registerXSiteActionSequencer, registerXSiteCommandReceiver, resetStatistics, setFirstTopologyAsMember, setStatisticsEnabled, stop
-
-
-
-
Method Detail
-
start
public void start()
- Overrides:
start
in classBasePerCacheInboundInvocationHandler
-
handle
public void handle(org.infinispan.commands.remote.CacheRpcCommand command, Reply reply, DeliverOrder order)
Description copied from interface:PerCacheInboundInvocationHandler
Handles theCacheRpcCommand
from other node.- 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
-
getLog
protected org.infinispan.util.logging.Log getLog()
- Specified by:
getLog
in classBasePerCacheInboundInvocationHandler
-
isTraceEnabled
protected boolean isTraceEnabled()
- Specified by:
isTraceEnabled
in classBasePerCacheInboundInvocationHandler
-
-