public class DefaultRpcExecutorService extends Object implements RpcExecutorService, LambdaLogger
Constructor and Description |
---|
DefaultRpcExecutorService(Vertx vertx,
org.jgroups.blocks.RpcDispatcher dispatcher) |
Modifier and Type | Method and Description |
---|---|
Logger |
log() |
<T> void |
remoteExecute(org.jgroups.blocks.MethodCall action,
Handler<AsyncResult<T>> handler) |
<T> T |
remoteExecute(org.jgroups.blocks.MethodCall action,
long timeout) |
<T> void |
remoteExecute(org.jgroups.blocks.MethodCall action,
long timeout,
Handler<AsyncResult<T>> handler) |
<T> void |
runAsync(java.util.function.Supplier<T> supplier,
Handler<AsyncResult<T>> handler) |
void |
stop() |
public DefaultRpcExecutorService(Vertx vertx, org.jgroups.blocks.RpcDispatcher dispatcher)
public <T> void runAsync(java.util.function.Supplier<T> supplier, Handler<AsyncResult<T>> handler)
runAsync
in interface RpcExecutorService
public <T> T remoteExecute(org.jgroups.blocks.MethodCall action, long timeout)
remoteExecute
in interface RpcExecutorService
public <T> void remoteExecute(org.jgroups.blocks.MethodCall action, Handler<AsyncResult<T>> handler)
remoteExecute
in interface RpcExecutorService
public <T> void remoteExecute(org.jgroups.blocks.MethodCall action, long timeout, Handler<AsyncResult<T>> handler)
remoteExecute
in interface RpcExecutorService
public void stop()
stop
in interface RpcExecutorService
public Logger log()
log
in interface LambdaLogger
Copyright © 2015. All rights reserved.