Package | Description |
---|---|
io.vertx.core | |
io.vertx.core.spi | |
io.vertx.core.spi.cluster |
Modifier and Type | Method and Description |
---|---|
static <T> Promise<T> |
Promise.promise()
Create a promise that hasn't completed yet
|
Modifier and Type | Method and Description |
---|---|
void |
Closeable.close(Promise<Void> completion)
Close this resource, the
completion promise must be notified when the operation has completed. |
void |
AbstractVerticle.start(Promise<Void> startPromise)
Start the verticle.
|
void |
Verticle.start(Promise<Void> startPromise)
Start the verticle instance.
|
void |
AbstractVerticle.stop(Promise<Void> stopPromise)
Stop the verticle.
|
void |
Verticle.stop(Promise<Void> stopPromise)
Stop the verticle instance.
|
Modifier and Type | Method and Description |
---|---|
<T> Future<T> |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Same as
Context.executeBlocking(Handler, Handler) but with an handler called when the operation completes |
default <T> Future<T> |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Like
WorkerExecutor.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
<T> Future<T> |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Same as
Vertx.executeBlocking(Handler, Handler) but with an handler called when the operation completes |
<T> Future<T> |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Same as
Context.executeBlocking(Handler, boolean, Handler) but with an handler called when the operation completes |
<T> Future<T> |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Same as
WorkerExecutor.executeBlocking(Handler, boolean, Handler) but with an handler called when the operation completes |
<T> Future<T> |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered)
Same as
Vertx.executeBlocking(Handler, boolean, Handler) but with an handler called when the operation completes |
<T> void |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Invoke
Context.executeBlocking(Handler, boolean, Handler) with order = true. |
default <T> void |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Like
WorkerExecutor.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
<T> void |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Like
Vertx.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
static <T> Future<T> |
Future.future(Handler<Promise<T>> handler)
Create a future that hasn't completed yet and that is passed to the
handler before it is returned. |
Modifier and Type | Method and Description |
---|---|
void |
VerticleFactory.createVerticle(String verticleName,
ClassLoader classLoader,
Promise<Callable<Verticle>> promise)
Create a verticle instance.
|
Modifier and Type | Method and Description |
---|---|
void |
ClusterManager.addRegistration(String address,
RegistrationInfo registrationInfo,
Promise<Void> promise)
Share a new messaging handler registration with other nodes in the cluster.
|
<K,V> void |
ClusterManager.getAsyncMap(String name,
Promise<AsyncMap<K,V>> promise)
Return an
AsyncMap for the given name . |
void |
ClusterManager.getCounter(String name,
Promise<Counter> promise)
Return a
Counter for the given name . |
void |
ClusterManager.getLockWithTimeout(String name,
long timeout,
Promise<Lock> promise)
|
void |
ClusterManager.getNodeInfo(String nodeId,
Promise<NodeInfo> promise)
Get details about a specific node in the cluster.
|
void |
ClusterManager.getRegistrations(String address,
Promise<List<RegistrationInfo>> promise)
Get the messaging handler currently registered in the cluster.
|
void |
ClusterManager.join(Promise<Void> promise)
Join the cluster.
|
void |
ClusterManager.leave(Promise<Void> promise)
Leave the cluster.
|
void |
ClusterManager.removeRegistration(String address,
RegistrationInfo registrationInfo,
Promise<Void> promise)
Signal removal of a messaging handler registration to other nodes in the cluster.
|
void |
NodeSelector.selectForPublish(Message<?> message,
Promise<Iterable<String>> promise)
Select a node for publishing the given
message . |
void |
NodeSelector.selectForSend(Message<?> message,
Promise<String> promise)
Select a node for sending the given
message . |
void |
ClusterManager.setNodeInfo(NodeInfo nodeInfo,
Promise<Void> promise)
Store the details about this clustered node.
|
Copyright © 2022 Eclipse. All rights reserved.