Class BaseBlockingRunnable
- java.lang.Object
-
- org.infinispan.remoting.inboundhandler.BaseBlockingRunnable
-
- All Implemented Interfaces:
java.lang.Runnable
,BlockingRunnable
- Direct Known Subclasses:
DefaultTopologyRunnable
public abstract class BaseBlockingRunnable extends java.lang.Object implements BlockingRunnable
Common logic to handleCacheRpcCommand
.- Since:
- 7.1
- Author:
- Pedro Ruivo
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler, org.infinispan.commands.remote.CacheRpcCommand command, Reply reply, boolean sync)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
afterInvoke()
protected java.util.concurrent.CompletableFuture<Response>
beforeInvoke()
protected void
onException(java.lang.Throwable throwable)
protected void
onFinally()
void
run()
java.lang.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 interfacejava.lang.Runnable
-
onFinally
protected void onFinally()
-
onException
protected void onException(java.lang.Throwable throwable)
-
afterInvoke
protected void afterInvoke()
-
beforeInvoke
protected java.util.concurrent.CompletableFuture<Response> beforeInvoke()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-