org.infinispan.remoting.inboundhandler

Class DefaultTopologyRunnable

java.lang.Object

org.infinispan.remoting.inboundhandler.BaseBlockingRunnable

org.infinispan.remoting.inboundhandler.DefaultTopologyRunnable

All Implemented Interfaces:

Runnable, BlockingRunnable

public class DefaultTopologyRunnable
extends BaseBlockingRunnable

The default Runnable for the remote commands receives.

It checks the command topology and ensures that the topology higher or equal is installed in this node.

Since:

8.0

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field and Description
protected int	commandTopologyId

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

command, handler, reply, response, sync

Constructor Summary

Constructors

Constructor and Description
DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler, CacheRpcCommand command, Reply reply, TopologyMode topologyMode, int commandTopologyId, boolean sync)

Method Summary

Modifier and Type	Method and Description
protected CompletableFuture<Response>	beforeInvoke()
boolean	isReady()
String	toString()

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

afterInvoke, onException, onFinally, run

Methods inherited from class java.lang.Object

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

Field Detail

commandTopologyId

protected final int commandTopologyId

Constructor Detail

DefaultTopologyRunnable

public DefaultTopologyRunnable(BasePerCacheInboundInvocationHandler handler,
                               CacheRpcCommand command,
                               Reply reply,
                               TopologyMode topologyMode,
                               int commandTopologyId,
                               boolean sync)

Method Detail

isReady

public boolean isReady()

Returns:

true if this Runnable is ready to be executed without blocking

beforeInvoke

protected CompletableFuture<Response> beforeInvoke()

Overrides:

beforeInvoke in class BaseBlockingRunnable

toString

public String toString()

Overrides:

toString in class BaseBlockingRunnable