org.infinispan.remoting.inboundhandler

Class NonTotalOrderTxPerCacheInboundInvocationHandler

java.lang.Object

org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler

org.infinispan.remoting.inboundhandler.NonTotalOrderTxPerCacheInboundInvocationHandler

All Implemented Interfaces:

PerCacheInboundInvocationHandler

public class NonTotalOrderTxPerCacheInboundInvocationHandler
extends BasePerCacheInboundInvocationHandler

A PerCacheInboundInvocationHandler implementation for non-total order caches.

Since:

7.1

Author:

Pedro Ruivo

Field Summary

Fields inherited from class org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler

NO_TOPOLOGY_COMMAND, remoteCommandsExecutor, stateTransferLock, stateTransferManager

Constructor Summary

Constructors

Constructor and Description
NonTotalOrderTxPerCacheInboundInvocationHandler()

Method Summary

Modifier and Type	Method and Description
protected BlockingRunnable	createReadyActionRunnable(CacheRpcCommand command, Reply reply, int commandTopologyId, boolean waitTransactionalData, boolean onExecutorService, ReadyAction readyAction)
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, PendingLockManager pendingLockManager)
protected boolean	isTraceEnabled()

Methods inherited from class org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler

createDefaultRunnable, executeOnExecutorService, extractCommandTopologyId, handleRunnable, injectDependencies, isCommandSentBeforeFirstTopology, unexpectedDeliverMode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NonTotalOrderTxPerCacheInboundInvocationHandler

public NonTotalOrderTxPerCacheInboundInvocationHandler()

Method Detail

inject

public void inject(LockManager lockManager,
                   ClusteringDependentLogic clusteringDependentLogic,
                   Configuration configuration,
                   PendingLockManager pendingLockManager)

handle

public void handle(CacheRpcCommand command,
                   Reply reply,
                   DeliverOrder order)

Description copied from interface: PerCacheInboundInvocationHandler

Handles the CacheRpcCommand from other node.

Parameters:

command - the CacheRpcCommand to handle-

reply - the return value is passed to this object in order to be sent back to the sender

order - the DeliverOrder in which the command was sent

getLog

protected Log getLog()

Specified by:

getLog in class BasePerCacheInboundInvocationHandler

isTraceEnabled

protected boolean isTraceEnabled()

Specified by:

isTraceEnabled in class BasePerCacheInboundInvocationHandler

createReadyActionRunnable

protected final BlockingRunnable createReadyActionRunnable(CacheRpcCommand command,
                                                           Reply reply,
                                                           int commandTopologyId,
                                                           boolean waitTransactionalData,
                                                           boolean onExecutorService,
                                                           ReadyAction readyAction)