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 inherited from class org.infinispan.remoting.inboundhandler.BaseBlockingRunnable

command, handler, reply, response

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected Response	beforeInvoke()
boolean	isReady()

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, toString, wait, wait, wait

Constructor Detail

DefaultTopologyRunnable

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

Method Detail

isReady

public boolean isReady()

Returns:

true if this Runnable is ready to be executed without blocking

beforeInvoke

protected Response beforeInvoke()
                         throws Exception

Overrides:

beforeInvoke in class BaseBlockingRunnable

Throws:

Exception