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
APerCacheInboundInvocationHandlerimplementation 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.LoggetLog()voidhandle(org.infinispan.commands.remote.CacheRpcCommand command, Reply reply, DeliverOrder order)Handles theCacheRpcCommandfrom other node.protected booleanisTraceEnabled()voidstart()-
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:
startin classBasePerCacheInboundInvocationHandler
-
handle
public void handle(org.infinispan.commands.remote.CacheRpcCommand command, Reply reply, DeliverOrder order)Description copied from interface:PerCacheInboundInvocationHandlerHandles theCacheRpcCommandfrom other node.- Parameters:
command- theCacheRpcCommandto handle-reply- the return value is passed to this object in order to be sent back to the senderorder- theDeliverOrderin which the command was sent
-
getLog
protected org.infinispan.util.logging.Log getLog()
- Specified by:
getLogin classBasePerCacheInboundInvocationHandler
-
isTraceEnabled
protected boolean isTraceEnabled()
- Specified by:
isTraceEnabledin classBasePerCacheInboundInvocationHandler
-
-