Package org.infinispan.remoting.inboundhandler

Class BaseBlockingRunnable

java.lang.Object

org.infinispan.remoting.inboundhandler.BaseBlockingRunnable

All Implemented Interfaces:

Runnable, BlockingRunnable

Direct Known Subclasses:

DefaultTopologyRunnable

public abstract class BaseBlockingRunnable
extends Object
implements BlockingRunnable

Common logic to handle CacheRpcCommand.

Since:

7.1

Author:

Pedro Ruivo

Field Summary

Fields

Modifier and Type	Field	Description
protected org.infinispan.commands.remote.CacheRpcCommand	command
protected BasePerCacheInboundInvocationHandler	handler
protected Reply	reply
protected Response	response
protected boolean	sync

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler, org.infinispan.commands.remote.CacheRpcCommand command, Reply reply, boolean sync)

Method Summary

Modifier and Type	Method	Description
protected void	afterInvoke()
protected CompletableFuture<Response>	beforeInvoke()
protected void	onException(Throwable throwable)
protected void	onFinally()
void	run()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.util.concurrent.BlockingRunnable

isReady

Field Detail

handler

protected final BasePerCacheInboundInvocationHandler handler

command

protected final org.infinispan.commands.remote.CacheRpcCommand command

reply

protected final Reply reply

sync

protected final boolean sync

response

protected Response response

Constructor Detail

BaseBlockingRunnable

protected BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler,
                               org.infinispan.commands.remote.CacheRpcCommand command,
                               Reply reply,
                               boolean sync)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

onFinally

protected void onFinally()

onException

protected void onException(Throwable throwable)

afterInvoke

protected void afterInvoke()

beforeInvoke

protected CompletableFuture<Response> beforeInvoke()

toString

public String toString()

Overrides:

toString in class Object