Class BasePerCacheInboundInvocationHandler
- java.lang.Object
-
- org.infinispan.remoting.inboundhandler.BasePerCacheInboundInvocationHandler
-
- All Implemented Interfaces:
PerCacheInboundInvocationHandler
- Direct Known Subclasses:
NonTotalOrderPerCacheInboundInvocationHandler
,NonTotalOrderTxPerCacheInboundInvocationHandler
,TotalOrderTxPerCacheInboundInvocationHandler
,TrianglePerCacheInboundInvocationHandler
public abstract class BasePerCacheInboundInvocationHandler extends Object implements PerCacheInboundInvocationHandler
Implementation with the default handling methods and utilities methods.- Since:
- 7.1
- Author:
- Pedro Ruivo
-
-
Field Summary
Fields Modifier and Type Field Description protected Configuration
configuration
protected BlockingTaskAwareExecutorService
remoteCommandsExecutor
protected StateTransferManager
stateTransferManager
-
Constructor Summary
Constructors Constructor Description BasePerCacheInboundInvocationHandler()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected abstract Log
getLog()
boolean
isCommandSentBeforeFirstTopology(int commandTopologyId)
boolean
isStopped()
protected abstract boolean
isTraceEnabled()
void
stop()
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.infinispan.remoting.inboundhandler.PerCacheInboundInvocationHandler
handle
-
-
-
-
Field Detail
-
remoteCommandsExecutor
protected BlockingTaskAwareExecutorService remoteCommandsExecutor
-
stateTransferManager
protected StateTransferManager stateTransferManager
-
configuration
protected Configuration configuration
-
-
Method Detail
-
stop
public void stop()
-
isStopped
public boolean isStopped()
-
isCommandSentBeforeFirstTopology
public final boolean isCommandSentBeforeFirstTopology(int commandTopologyId)
-
getLog
protected abstract Log getLog()
-
isTraceEnabled
protected abstract boolean isTraceEnabled()
-
-