public abstract class BaseBlockingRunnable extends Object implements BlockingRunnable
CacheRpcCommand
.Modifier and Type | Field and Description |
---|---|
protected CacheRpcCommand |
command |
protected BasePerCacheInboundInvocationHandler |
handler |
protected Reply |
reply |
protected Response |
response |
protected boolean |
sync |
Modifier | Constructor and Description |
---|---|
protected |
BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler,
CacheRpcCommand command,
Reply reply,
boolean sync) |
Modifier and Type | Method and Description |
---|---|
protected void |
afterInvoke() |
protected CompletableFuture<Response> |
beforeInvoke() |
protected void |
onException(Throwable throwable) |
protected void |
onFinally() |
void |
run() |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
isReady
protected final BasePerCacheInboundInvocationHandler handler
protected final CacheRpcCommand command
protected final Reply reply
protected final boolean sync
protected Response response
protected BaseBlockingRunnable(BasePerCacheInboundInvocationHandler handler, CacheRpcCommand command, Reply reply, boolean sync)
protected void onFinally()
protected void onException(Throwable throwable)
protected void afterInvoke()
protected CompletableFuture<Response> beforeInvoke()
Copyright © 2021 JBoss by Red Hat. All rights reserved.