public abstract class BasePerCacheInboundInvocationHandler extends Object implements PerCacheInboundInvocationHandler
Modifier and Type | Field and Description |
---|---|
protected static int |
NO_TOPOLOGY_COMMAND |
protected BlockingTaskAwareExecutorService |
remoteCommandsExecutor |
protected StateTransferLock |
stateTransferLock |
protected StateTransferManager |
stateTransferManager |
Constructor and Description |
---|
BasePerCacheInboundInvocationHandler() |
Modifier and Type | Method and Description |
---|---|
protected BlockingRunnable |
createDefaultRunnable(CacheRpcCommand command,
Reply reply,
int commandTopologyId,
boolean waitTransactionalData,
boolean onExecutorService) |
protected boolean |
executeOnExecutorService(DeliverOrder order,
CacheRpcCommand command) |
protected static int |
extractCommandTopologyId(CacheRpcCommand command) |
protected abstract Log |
getLog() |
protected void |
handleRunnable(BlockingRunnable runnable,
boolean onExecutorService) |
void |
injectDependencies(BlockingTaskAwareExecutorService remoteCommandsExecutor,
ResponseGenerator responseGenerator,
CancellationService cancellationService,
StateTransferLock stateTransferLock,
StateTransferManager stateTransferManager) |
boolean |
isCommandSentBeforeFirstTopology(int commandTopologyId) |
protected abstract boolean |
isTraceEnabled() |
protected void |
unexpectedDeliverMode(ReplicableCommand command,
DeliverOrder deliverOrder) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handle
protected static final int NO_TOPOLOGY_COMMAND
protected BlockingTaskAwareExecutorService remoteCommandsExecutor
protected StateTransferLock stateTransferLock
protected StateTransferManager stateTransferManager
public BasePerCacheInboundInvocationHandler()
protected static int extractCommandTopologyId(CacheRpcCommand command)
public void injectDependencies(BlockingTaskAwareExecutorService remoteCommandsExecutor, ResponseGenerator responseGenerator, CancellationService cancellationService, StateTransferLock stateTransferLock, StateTransferManager stateTransferManager)
protected final void unexpectedDeliverMode(ReplicableCommand command, DeliverOrder deliverOrder)
protected final void handleRunnable(BlockingRunnable runnable, boolean onExecutorService)
public final boolean isCommandSentBeforeFirstTopology(int commandTopologyId)
protected final BlockingRunnable createDefaultRunnable(CacheRpcCommand command, Reply reply, int commandTopologyId, boolean waitTransactionalData, boolean onExecutorService)
protected abstract Log getLog()
protected abstract boolean isTraceEnabled()
protected final boolean executeOnExecutorService(DeliverOrder order, CacheRpcCommand command)
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.