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 RpcExecutorServicepublic <T> T remoteExecute(org.jgroups.blocks.MethodCall action,
long timeout)
remoteExecute in interface RpcExecutorServicepublic <T> void remoteExecute(org.jgroups.blocks.MethodCall action,
Handler<AsyncResult<T>> handler)
remoteExecute in interface RpcExecutorServicepublic <T> void remoteExecute(org.jgroups.blocks.MethodCall action,
long timeout,
Handler<AsyncResult<T>> handler)
remoteExecute in interface RpcExecutorServicepublic void stop()
stop in interface RpcExecutorServicepublic Logger log()
log in interface LambdaLoggerCopyright © 2015. All rights reserved.