| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
AmqpConnection.close()
Like
AmqpConnection.close(Handler) but returns a Future of the asynchronous result |
Future<Void> |
AmqpSender.close()
Like
AmqpSender.close(Handler) but returns a Future of the asynchronous result |
Future<Void> |
AmqpReceiver.close()
Like
AmqpReceiver.close(Handler) but returns a Future of the asynchronous result |
Future<Void> |
AmqpClient.close()
Like
AmqpClient.close(Handler) but returns a Future of the asynchronous result |
Future<AmqpConnection> |
AmqpClient.connect()
Like
AmqpClient.connect(Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
AmqpConnection.createAnonymousSender()
Like
AmqpConnection.createAnonymousSender(Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpConnection.createDynamicReceiver()
Like
AmqpConnection.createDynamicReceiver(Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpConnection.createReceiver(String address)
Like
AmqpConnection.createReceiver(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpClient.createReceiver(String address)
Like
AmqpClient.createReceiver(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpConnection.createReceiver(String address,
AmqpReceiverOptions receiverOptions)
Like
AmqpConnection.createReceiver(String, AmqpReceiverOptions, Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpClient.createReceiver(String address,
AmqpReceiverOptions receiverOptions)
Like
AmqpClient.createReceiver(String, AmqpReceiverOptions, Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
AmqpConnection.createSender(String address)
Like
AmqpConnection.createSender(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
AmqpClient.createSender(String address)
Like
AmqpClient.createSender(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
AmqpConnection.createSender(String address,
AmqpSenderOptions options)
Like
AmqpConnection.createSender(String, AmqpSenderOptions, Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
AmqpClient.createSender(String address,
AmqpSenderOptions options)
Like
AmqpClient.createSender(String, AmqpSenderOptions, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AmqpSender.sendWithAck(AmqpMessage message)
Like
AmqpSender.sendWithAck(AmqpMessage, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<List<com.datastax.driver.core.Row>> |
ResultSet.all()
Like
ResultSet.all(Handler) but returns a Future of the asynchronous result. |
Future<Void> |
CassandraClient.close()
Like
CassandraClient.close(Handler) but returns a Future of the asynchronous result. |
Future<Void> |
Mapper.delete(List<Object> primaryKey)
Like
Mapper.delete(List, Handler) but returns a Future of the asynchronous result. |
Future<ResultSet> |
CassandraClient.execute(com.datastax.driver.core.Statement statement)
Like
CassandraClient.execute(Statement, Handler) but returns a Future of the asynchronous result. |
<R> Future<R> |
CassandraClient.execute(com.datastax.driver.core.Statement statement,
java.util.stream.Collector<com.datastax.driver.core.Row,?,R> collector)
Like
CassandraClient.execute(Statement, Collector, Handler) but returns a Future of the asynchronous result. |
Future<ResultSet> |
CassandraClient.execute(String query)
Like
CassandraClient.execute(String, Handler) but returns a Future of the asynchronous result. |
<R> Future<R> |
CassandraClient.execute(String query,
java.util.stream.Collector<com.datastax.driver.core.Row,?,R> collector)
Like
CassandraClient.execute(String, Collector, Handler) but returns a Future of the asynchronous result. |
Future<List<com.datastax.driver.core.Row>> |
CassandraClient.executeWithFullFetch(com.datastax.driver.core.Statement statement)
Like
CassandraClient.executeWithFullFetch(Statement, Handler) but returns a Future of the asynchronous result. |
Future<List<com.datastax.driver.core.Row>> |
CassandraClient.executeWithFullFetch(String query)
Like
CassandraClient.executeWithFullFetch(String, Handler) but returns a Future of the asynchronous result. |
Future<Void> |
ResultSet.fetchMoreResults()
Like
ResultSet.fetchMoreResults(Handler) but returns a Future of the asynchronous result. |
Future<T> |
Mapper.get(List<Object> primaryKey)
Like
Mapper.get(List, Handler) but returns a Future of the asynchronous result. |
Future<com.datastax.driver.core.Row> |
ResultSet.one()
Like
ResultSet.one(Handler) but returns a Future of the asynchronous result. |
Future<com.datastax.driver.core.PreparedStatement> |
CassandraClient.prepare(String query)
Like
CassandraClient.prepare(String, Handler) but returns a Future of the asynchronous result. |
Future<CassandraRowStream> |
CassandraClient.queryStream(com.datastax.driver.core.Statement statement)
Like
CassandraClient.queryStream(Statement, Handler) but returns a Future of the asynchronous result. |
Future<CassandraRowStream> |
CassandraClient.queryStream(String sql)
Like
CassandraClient.queryStream(String, Handler) but returns a Future of the asynchronous result. |
Future<Void> |
Mapper.save(T entity)
Like
Mapper.save(Object, Handler) but returns a Future of the asynchronous result. |
Future<List<com.datastax.driver.core.Row>> |
ResultSet.several(int amount)
Like
ResultSet.several(int, Handler) but returns a Future of the asynchronous result. |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
CircuitBreaker.execute(Handler<Promise<T>> command)
Same as
CircuitBreaker.executeWithFallback(Handler, Function) but using the circuit breaker default fallback. |
<T> Future<T> |
CircuitBreaker.executeWithFallback(Handler<Promise<T>> command,
java.util.function.Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
| Modifier and Type | Method and Description |
|---|---|
Future<JsonObject> |
ConfigRetriever.getConfig()
Like
ConfigRetriever.getConfig(Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CompositeFuture
The composite future wraps a list of
futures, it is useful when several futures
needs to be coordinated. |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
Vertx.close()
Stop the the Vertx instance and release any resources held by it.
|
static Future<Vertx> |
Vertx.clusteredVertx(VertxOptions options)
Same as
Vertx.clusteredVertx(VertxOptions, Handler) but with an handler called when the operation completes |
default <U> Future<U> |
Future.compose(java.util.function.Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
Future<String> |
Vertx.deployVerticle(Class<? extends Verticle> verticleClass,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle, DeploymentOptions) but Verticle instance is created by invoking the
default constructor of verticleClass. |
Future<String> |
Vertx.deployVerticle(String name)
Deploy a verticle instance given a name.
|
Future<String> |
Vertx.deployVerticle(String name,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle) but DeploymentOptions are provided to configure the
deployment. |
Future<String> |
Vertx.deployVerticle(java.util.function.Supplier<Verticle> verticleSupplier,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle, DeploymentOptions) but Verticle instance is created by invoking the
verticleSupplier. |
Future<String> |
Vertx.deployVerticle(Verticle verticle)
Deploy a verticle instance that you have created yourself.
|
Future<String> |
Vertx.deployVerticle(Verticle verticle,
DeploymentOptions options)
Like
Vertx.deployVerticle(Verticle) but DeploymentOptions are provided to configure the
deployment. |
default <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> |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler)
Same as
Vertx.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. |
default <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 |
default <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 |
default <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 |
static <T> Future<T> |
Future.failedFuture(String failureMessage)
Create a failed future with the specified failure message.
|
static <T> Future<T> |
Future.failedFuture(Throwable t)
Create a failed future with the specified failure cause.
|
Future<T> |
Promise.future() |
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. |
default <U> Future<U> |
Future.map(java.util.function.Function<T,U> mapper)
Apply a
mapper function on this future. |
default <V> Future<V> |
Future.map(V value)
Map the result of a future to a specific
value. |
default <V> Future<V> |
Future.mapEmpty()
Map the result of a future to
null. |
default Future<T> |
Future.otherwise(java.util.function.Function<Throwable,T> mapper)
Apply a
mapper function on this future. |
default Future<T> |
Future.otherwise(T value)
Map the failure of a future to a specific
value. |
default Future<T> |
Future.otherwiseEmpty()
Map the failure of a future to
null. |
default Future<T> |
Future.recover(java.util.function.Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
Future<T> |
Future.setHandler(Handler<AsyncResult<T>> handler)
Set a handler for the result.
|
static <T> Future<T> |
Future.succeededFuture()
Create a succeeded future with a null result
|
static <T> Future<T> |
Future.succeededFuture(T result)
Created a succeeded future with the specified result.
|
Future<Void> |
Vertx.undeploy(String deploymentID)
Undeploy a verticle deployment.
|
| Modifier and Type | Method and Description |
|---|---|
static <T1,T2> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2,T3> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.all(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.all(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.all(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.all(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.all(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.all(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.all(Future, Future) but with 6 futures. |
static <T1,T2> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when any futures is succeeded, failed when all futures are failed.
|
static <T1,T2> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when any futures is succeeded, failed when all futures are failed.
|
static <T1,T2,T3> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.any(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.any(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.any(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.any(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.any(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.any(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.any(Future, Future) but with 6 futures. |
static <T1,T2> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2)
Return a composite future, succeeded when all futures are succeeded, failed when any future is failed.
|
static <T1,T2,T3> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.join(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.join(Future, Future) but with 3 futures. |
static <T1,T2,T3> CompositeFuture |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3)
Like
CompositeFuture.join(Future, Future) but with 3 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4)
Like
CompositeFuture.join(Future, Future) but with 4 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5)
Like
CompositeFuture.join(Future, Future) but with 5 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
static <T1,T2,T3,T4,T5,T6> |
CompositeFuture.join(Future<T1> f1,
Future<T2> f2,
Future<T3> f3,
Future<T4> f4,
Future<T5> f5,
Future<T6> f6)
Like
CompositeFuture.join(Future, Future) but with 6 futures. |
| Modifier and Type | Method and Description |
|---|---|
static CompositeFuture |
CompositeFuture.all(List<Future> futures)
Like
CompositeFuture.all(Future, Future) but with a list of futures. |
static CompositeFuture |
CompositeFuture.any(List<Future> futures)
Like
CompositeFuture.any(Future, Future) but with a list of futures. |
default <U> Future<U> |
Future.compose(java.util.function.Function<T,Future<U>> mapper)
Compose this future with a
mapper function. |
static CompositeFuture |
CompositeFuture.join(List<Future> futures)
Like
CompositeFuture.join(Future, Future) but with a list of futures. |
default Future<T> |
Future.recover(java.util.function.Function<Throwable,Future<T>> mapper)
Handles a failure of this Future by returning the result of another Future.
|
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock)
Like
DatagramSocket.blockMulticastGroup(String, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String networkInterface,
String sourceToBlock)
Like
DatagramSocket.blockMulticastGroup(String, String, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.close()
Closes the
DatagramSocket. |
default Future<DatagramSocket> |
DatagramSocket.listen(int port,
String host)
Like
DatagramSocket.listen(int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.listenMulticastGroup(String multicastAddress)
Like
DatagramSocket.listenMulticastGroup(String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.listenMulticastGroup(String multicastAddress,
String networkInterface,
String source)
Like
DatagramSocket.listenMulticastGroup(String, String, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.send(Buffer packet,
int port,
String host)
Like
DatagramSocket.send(Buffer, int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.send(String str,
int port,
String host)
Like
DatagramSocket.send(String, int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.send(String str,
String enc,
int port,
String host)
Like
DatagramSocket.send(String, String, int, String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.unlistenMulticastGroup(String multicastAddress)
Like
DatagramSocket.unlistenMulticastGroup(String, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
String networkInterface,
String source)
Like
DatagramSocket.unlistenMulticastGroup(String, String, String, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
default Future<String> |
DnsClient.lookup(String name)
Like
DnsClient.lookup(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.lookup4(String name)
Like
DnsClient.lookup4(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.lookup6(String name)
Like
DnsClient.lookup6(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveA(String name)
Like
DnsClient.resolveA(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveAAAA(String name)
Like
DnsClient.resolveAAAA(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveCNAME(String name)
Like
DnsClient.resolveCNAME(String, Handler) but returns a Future of the asynchronous result |
default Future<List<MxRecord>> |
DnsClient.resolveMX(String name)
Like
DnsClient.resolveMX(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveNS(String name)
Like
DnsClient.resolveNS(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.resolvePTR(String name)
Like
DnsClient.resolvePTR(String, Handler) but returns a Future of the asynchronous result |
default Future<List<SrvRecord>> |
DnsClient.resolveSRV(String name)
Like
DnsClient.resolveSRV(String, Handler) but returns a Future of the asynchronous result |
default Future<List<String>> |
DnsClient.resolveTXT(String name)
Like
DnsClient.resolveTXT(String, Handler) but returns a Future of the asynchronous result |
default Future<String> |
DnsClient.reverseLookup(String ipaddress)
Like
DnsClient.reverseLookup(String, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
MessageProducer.close()
Closes the producer, this method should be called when the message producer is not used anymore.
|
Future<Void> |
MessageProducer.end()
Closes the producer, calls
MessageProducer.close() |
default <R> Future<Message<R>> |
Message.replyAndRequest(Object message)
Like
Message.replyAndRequest(Object, Handler) but returns a Future of the asynchronous result |
default <R> Future<Message<R>> |
Message.replyAndRequest(Object message,
DeliveryOptions options)
Like
Message.replyAndRequest(Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result |
default <T> Future<Message<T>> |
EventBus.request(String address,
Object message)
Like
EventBus.request(String, Object, Handler) but returns a Future of the asynchronous result |
default <T> Future<Message<T>> |
EventBus.request(String address,
Object message,
DeliveryOptions options)
Like
EventBus.request(String, Object, DeliveryOptions, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
FileSystem.chmod(String path,
String perms)
Like
FileSystem.chmod(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.chmodRecursive(String path,
String perms,
String dirPerms)
Like
FileSystem.chmodRecursive(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.chown(String path,
String user,
String group)
Like
FileSystem.chown(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncFile.close()
Close the file.
|
Future<Void> |
FileSystem.copy(String from,
String to)
Like
FileSystem.copy(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.copy(String from,
String to,
CopyOptions options)
Like
FileSystem.copy(String, String, CopyOptions, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.copyRecursive(String from,
String to,
boolean recursive)
Like
FileSystem.copyRecursive(String, String, boolean, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.createFile(String path)
Like
FileSystem.createFile(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.createFile(String path,
String perms)
Like
FileSystem.createFile(String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempDirectory(String prefix)
Like
FileSystem.createTempDirectory(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempDirectory(String prefix,
String perms)
Like
FileSystem.createTempDirectory(String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempDirectory(String dir,
String prefix,
String perms)
Like
FileSystem.createTempDirectory(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempFile(String prefix,
String suffix)
Like
FileSystem.createTempFile(String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempFile(String prefix,
String suffix,
String perms)
Like
FileSystem.createTempFile(String, String, String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.createTempFile(String dir,
String prefix,
String suffix,
String perms)
Like
FileSystem.createTempFile(String, String, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.delete(String path)
Like
FileSystem.delete(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.deleteRecursive(String path,
boolean recursive)
Like
FileSystem.deleteRecursive(String, boolean, Handler) but returns a Future of the asynchronous result |
Future<Boolean> |
FileSystem.exists(String path)
Like
FileSystem.exists(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncFile.flush()
Flush any writes made to this file to underlying persistent storage.
|
Future<FileSystemProps> |
FileSystem.fsProps(String path)
Like
FileSystem.fsProps(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.link(String link,
String existing)
Like
FileSystem.link(String, String, Handler) but returns a Future of the asynchronous result |
Future<FileProps> |
FileSystem.lprops(String path)
Like
FileSystem.lprops(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdir(String path)
Like
FileSystem.mkdir(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdir(String path,
String perms)
Like
FileSystem.mkdir(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdirs(String path)
Like
FileSystem.mkdirs(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.mkdirs(String path,
String perms)
Like
FileSystem.mkdirs(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.move(String from,
String to)
Like
FileSystem.move(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.move(String from,
String to,
CopyOptions options)
Like
FileSystem.move(String, String, CopyOptions, Handler) but returns a Future of the asynchronous result |
Future<AsyncFile> |
FileSystem.open(String path,
OpenOptions options)
Like
FileSystem.open(String, OpenOptions, Handler) but returns a Future of the asynchronous result |
Future<FileProps> |
FileSystem.props(String path)
Like
FileSystem.props(String, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length)
Like
AsyncFile.read(Buffer, int, long, int, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
FileSystem.readDir(String path)
Like
FileSystem.readDir(String, Handler) but returns a Future of the asynchronous result |
Future<List<String>> |
FileSystem.readDir(String path,
String filter)
Like
FileSystem.readDir(String, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
FileSystem.readFile(String path)
Like
FileSystem.readFile(String, Handler) but returns a Future of the asynchronous result |
Future<String> |
FileSystem.readSymlink(String link)
Like
FileSystem.readSymlink(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.symlink(String link,
String existing)
Like
FileSystem.symlink(String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.truncate(String path,
long len)
Like
FileSystem.truncate(String, long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.unlink(String link)
Like
FileSystem.unlink(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
AsyncFile.write(Buffer buffer,
long position)
Like
AsyncFile.write(Buffer, long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
FileSystem.writeFile(String path,
Buffer data)
Like
FileSystem.writeFile(String, Buffer, Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HttpClientRequest
Represents a client-side HTTP request.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Buffer> |
HttpClientResponse.body()
Convenience method for receiving the entire request body in one piece.
|
Future<Buffer> |
HttpServerRequest.body()
Convenience method for receiving the entire request body in one piece.
|
Future<Void> |
ServerWebSocket.close()
Close the WebSocket sending the default close frame.
|
Future<Void> |
HttpServer.close()
Close the server.
|
Future<Void> |
HttpConnection.close()
Close the connection and all the currently active streams.
|
Future<Void> |
WebSocketBase.close()
Close the WebSocket sending the default close frame.
|
Future<Void> |
WebSocketBase.close(short statusCode)
Close the WebSocket sending a close frame with specified status code.
|
Future<Void> |
WebSocketBase.close(short statusCode,
String reason)
Close sending a close frame with specified status code and reason.
|
Future<Void> |
HttpServerResponse.end()
Ends the response.
|
Future<Void> |
HttpClientRequest.end()
Ends the request.
|
Future<Void> |
WebSocketBase.end()
Ends the stream.
|
Future<Void> |
HttpServerResponse.end(Buffer chunk)
Same as
HttpServerResponse.end() but writes some data to the response body before ending. |
Future<Void> |
HttpClientRequest.end(Buffer chunk)
Same as
HttpClientRequest.end() but writes some data to the request body before ending. |
Future<Void> |
HttpServerResponse.end(String chunk)
Same as
HttpServerResponse.end(Buffer) but writes a String in UTF-8 encoding before ending the response. |
Future<Void> |
HttpClientRequest.end(String chunk)
Same as
HttpClientRequest.end(Buffer) but writes a String in UTF-8 encoding |
Future<Void> |
HttpServerResponse.end(String chunk,
String enc)
Same as
HttpServerResponse.end(Buffer) but writes a String with the specified encoding before ending the response. |
Future<Void> |
HttpClientRequest.end(String chunk,
String enc)
Same as
HttpClientRequest.end(Buffer) but writes a String with the specified encoding |
default Future<HttpClientResponse> |
HttpClient.getNow(int port,
String host,
String requestURI)
Like
HttpClient.getNow(int, String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.getNow(RequestOptions options)
Like
HttpClient.getNow(RequestOptions, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.getNow(String requestURI)
Like
HttpClient.getNow(String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.getNow(String host,
String requestURI)
Like
HttpClient.getNow(String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(int port,
String host,
String requestURI)
Like
HttpClient.headNow(int, String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(RequestOptions options)
Like
HttpClient.headNow(RequestOptions, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(String requestURI)
Like
HttpClient.headNow(String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.headNow(String host,
String requestURI)
Like
HttpClient.headNow(String, String, Handler) but returns a Future of the asynchronous result |
Future<HttpServer> |
HttpServer.listen()
Tell the server to start listening.
|
Future<HttpServer> |
HttpServer.listen(int port)
Like
HttpServer.listen(int, String) but the server will listen on host "0.0.0.0" and port specified here ignoring
any value in the HttpServerOptions that was used when creating the server. |
Future<HttpServer> |
HttpServer.listen(int port,
String host)
Tell the server to start listening.
|
Future<HttpServer> |
HttpServer.listen(SocketAddress address)
Like
HttpServer.listen(SocketAddress, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(int port,
String host,
String requestURI)
Like
HttpClient.optionsNow(int, String, String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(RequestOptions options)
Like
HttpClient.optionsNow(RequestOptions, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(String requestURI)
Like
HttpClient.optionsNow(String, Handler) but returns a Future of the asynchronous result |
default Future<HttpClientResponse> |
HttpClient.optionsNow(String host,
String requestURI)
Like
HttpClient.optionsNow(String, String, Handler) but returns a Future of the asynchronous result |
Future<Buffer> |
HttpConnection.ping(Buffer data)
Same as
HttpConnection.ping(Buffer, Handler) but returns a Future of the asynchronous result |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String path)
Same as
HttpServerResponse.push(HttpMethod, String, Handler) but with an handler called when the operation completes |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String path,
MultiMap headers)
Same as
HttpServerResponse.push(HttpMethod, String, MultiMap, Handler) but with an handler called when the operation completes |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String host,
String path)
Same as
HttpServerResponse.push(HttpMethod, String, String, Handler) but with an handler called when the operation completes |
default Future<HttpServerResponse> |
HttpServerResponse.push(HttpMethod method,
String host,
String path,
MultiMap headers)
Same as
HttpServerResponse.push(HttpMethod, String, String, MultiMap, Handler) but with an handler called when the operation completes |
default Future<Void> |
HttpServerResponse.sendFile(String filename)
Same as
HttpServerResponse.sendFile(String, long) using offset @code{0} which means starting from the beginning of the file. |
default Future<Void> |
HttpServerResponse.sendFile(String filename,
long offset)
Same as
HttpServerResponse.sendFile(String, long, long) using length @code{Long.MAX_VALUE} which means until the end of the
file. |
default Future<Void> |
HttpServerResponse.sendFile(String filename,
long offset,
long length)
Ask the OS to stream a file as specified by
filename directly
from disk to the outgoing connection, bypassing userspace altogether
(where supported by the underlying operating system. |
Future<Void> |
HttpConnection.updateSettings(Http2Settings settings)
Send to the remote endpoint an update of the server settings.
|
Future<WebSocket> |
HttpClient.webSocket(int port,
String host,
String requestURI)
Like
HttpClient.webSocket(int, String, String, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocket(String requestURI)
Like
HttpClient.webSocket(String, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocket(String host,
String requestURI)
Like
HttpClient.webSocket(String, String, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocket(WebSocketConnectOptions options)
Like
HttpClient.webSocket(WebSocketConnectOptions, Handler) but returns a Future of the asynchronous result |
Future<WebSocket> |
HttpClient.webSocketAbs(String url,
MultiMap headers,
WebsocketVersion version,
List<String> subProtocols)
Like
HttpClient.webSocketAbs(String, MultiMap, WebsocketVersion, List, Handler) but returns a Future of the asynchronous result |
Future<Void> |
HttpServerResponse.write(String chunk)
Write a
String to the response body, encoded in UTF-8. |
Future<Void> |
HttpClientRequest.write(String chunk)
Write a
String to the request body, encoded as UTF-8. |
Future<Void> |
HttpServerResponse.write(String chunk,
String enc)
Write a
String to the response body, encoded using the encoding enc. |
Future<Void> |
HttpClientRequest.write(String chunk,
String enc)
Write a
String to the request body, encoded using the encoding enc. |
Future<Void> |
WebSocketBase.writeBinaryMessage(Buffer data)
Writes a (potentially large) piece of binary data to the connection.
|
Future<Void> |
WebSocketBase.writeFinalBinaryFrame(Buffer data)
Write a final WebSocket binary frame to the connection
|
Future<Void> |
WebSocketBase.writeFinalTextFrame(String text)
Write a final WebSocket text frame to the connection
|
Future<Void> |
WebSocketBase.writeFrame(WebSocketFrame frame)
Write a WebSocket frame to the connection
|
Future<Void> |
WebSocketBase.writeTextMessage(String text)
Writes a (potentially large) piece of text data to the connection.
|
| Modifier and Type | Method and Description |
|---|---|
java.util.function.Function<HttpClientResponse,Future<HttpClientRequest>> |
HttpClient.redirectHandler() |
| Modifier and Type | Method and Description |
|---|---|
void |
ServerWebSocket.setHandshake(Future<Integer> future)
Deprecated.
instead use
ServerWebSocket.setHandshake(Promise) |
| Modifier and Type | Method and Description |
|---|---|
HttpClient |
HttpClient.redirectHandler(java.util.function.Function<HttpClientResponse,Future<HttpClientRequest>> handler)
Set a redirect handler for the http client.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
NetSocket.close()
Close the NetSocket
|
Future<Void> |
NetServer.close()
Close the server.
|
Future<NetSocket> |
NetClient.connect(int port,
String host)
Like
NetClient.connect(int, String, Handler) but returns a Future of the asynchronous result |
Future<NetSocket> |
NetClient.connect(int port,
String host,
String serverName)
Like
NetClient.connect(int, String, String, Handler) but returns a Future of the asynchronous result |
Future<NetSocket> |
NetClient.connect(SocketAddress remoteAddress)
Like
NetClient.connect(SocketAddress, Handler) but returns a Future of the asynchronous result |
Future<NetSocket> |
NetClient.connect(SocketAddress remoteAddress,
String serverName)
Like
NetClient.connect(SocketAddress, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
NetSocket.end()
Calls
NetSocket.close() |
Future<NetServer> |
NetServer.listen()
Start listening on the port and host as configured in the
NetServerOptions used when
creating the server. |
Future<NetServer> |
NetServer.listen(int port)
Start listening on the specified port and host "0.0.0.0", ignoring port and host configured in the
NetServerOptions used when creating the server. |
Future<NetServer> |
NetServer.listen(int port,
String host)
Start listening on the specified port and host, ignoring port and host configured in the
NetServerOptions used when
creating the server. |
Future<NetServer> |
NetServer.listen(SocketAddress localAddress)
Start listening on the specified local address, ignoring port and host configured in the
NetServerOptions used when
creating the server. |
default Future<Void> |
NetSocket.sendFile(String filename)
Tell the operating system to stream a file as specified by
filename directly from disk to the outgoing connection,
bypassing userspace altogether (where supported by the underlying operating system. |
default Future<Void> |
NetSocket.sendFile(String filename,
long offset)
Tell the operating system to stream a file as specified by
filename directly from disk to the outgoing connection,
bypassing userspace altogether (where supported by the underlying operating system. |
default Future<Void> |
NetSocket.sendFile(String filename,
long offset,
long length)
Tell the operating system to stream a file as specified by
filename directly from disk to the outgoing connection,
bypassing userspace altogether (where supported by the underlying operating system. |
default Future<Void> |
NetSocket.upgradeToSsl()
Like
NetSocket.upgradeToSsl(Handler) but returns a Future of the asynchronous result |
default Future<Void> |
NetSocket.upgradeToSsl(String serverName)
Like
NetSocket.upgradeToSsl(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
NetSocket.write(String str)
Write a
String to the connection, encoded in UTF-8. |
Future<Void> |
NetSocket.write(String str,
String enc)
Write a
String to the connection, encoded using the encoding enc. |
| Modifier and Type | Method and Description |
|---|---|
default Future<Long> |
Counter.addAndGet(long value)
Same as
Counter.addAndGet(long, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
AsyncMap.clear()
Same as
AsyncMap.clear(Handler) but returns a Future of the asynchronous result |
default Future<Boolean> |
Counter.compareAndSet(long expected,
long value)
Same as
Counter.compareAndSet(long, long, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.decrementAndGet()
Same as
Counter.decrementAndGet(Handler) but returns a Future of the asynchronous result |
default Future<Map<K,V>> |
AsyncMap.entries()
Same as
AsyncMap.entries(Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.get()
Same as
Counter.get(Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.get(K k)
Same as
#get(K, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.getAndAdd(long value)
Same as
Counter.getAndAdd(long, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.getAndIncrement()
Same as
Counter.getAndIncrement(Handler) but returns a Future of the asynchronous result |
default <K,V> Future<AsyncMap<K,V>> |
SharedData.getAsyncMap(String name)
Same as
SharedData.getAsyncMap(String, Handler) but returns a Future of the asynchronous result |
default <K,V> Future<AsyncMap<K,V>> |
SharedData.getClusterWideMap(String name)
Same as
SharedData.getClusterWideMap(String, Handler) but returns a Future of the asynchronous result |
default Future<Counter> |
SharedData.getCounter(String name)
Same as
SharedData.getCounter(String, Handler) but returns a Future of the asynchronous result |
default <K,V> Future<AsyncMap<K,V>> |
SharedData.getLocalAsyncMap(String name)
Same as
SharedData.getLocalAsyncMap(String, Handler) but returns a Future of the asynchronous result |
default Future<Counter> |
SharedData.getLocalCounter(String name)
Same as
SharedData.getLocalCounter(String, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLocalLock(String name)
Same as
SharedData.getLocalLock(String, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLocalLockWithTimeout(String name,
long timeout)
Same as
SharedData.getLocalLockWithTimeout(String, long, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLock(String name)
Same as
SharedData.getLock(String, Handler) but returns a Future of the asynchronous result |
default Future<Lock> |
SharedData.getLockWithTimeout(String name,
long timeout)
Same as
SharedData.getLockWithTimeout(String, long, Handler) but returns a Future of the asynchronous result |
default Future<Long> |
Counter.incrementAndGet()
Same as
Counter.incrementAndGet(Handler) but returns a Future of the asynchronous result |
default Future<Set<K>> |
AsyncMap.keys()
Same as
AsyncMap.keys(Handler) but returns a Future of the asynchronous result |
default Future<Void> |
AsyncMap.put(K k,
V v)
Same as
#put(K, V, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
AsyncMap.put(K k,
V v,
long ttl)
Same as
#put(K, V, long, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.putIfAbsent(K k,
V v)
Same as
#putIfAbsent(K, V, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.putIfAbsent(K k,
V v,
long ttl)
Same as
#putIfAbsent(K, V, long, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.remove(K k)
Same as
#remove(K, Handler) but returns a Future of the asynchronous result |
default Future<Boolean> |
AsyncMap.removeIfPresent(K k,
V v)
Same as
#removeIfPresent(K, V, Handler) but returns a Future of the asynchronous result |
default Future<V> |
AsyncMap.replace(K k,
V v)
Same as
#replace(K, V, Handler) but returns a Future of the asynchronous result |
default Future<Boolean> |
AsyncMap.replaceIfPresent(K k,
V oldValue,
V newValue)
Same as
#replaceIfPresent(K, V, V, Handler) but returns a Future of the asynchronous result |
default Future<Integer> |
AsyncMap.size()
Same as
AsyncMap.size(Handler) but returns a Future of the asynchronous result |
default Future<List<V>> |
AsyncMap.values()
Same as
AsyncMap.values(Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
FutureFactory.failedFuture(Throwable t) |
<T> Future<T> |
FutureFactory.failureFuture(String failureMessage) |
<T> Future<T> |
FutureFactory.future() |
<T> Future<T> |
FutureFactory.succeededFuture() |
<T> Future<T> |
FutureFactory.succeededFuture(T result) |
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
WriteStream.end()
Ends the stream.
|
default Future<Void> |
WriteStream.end(T data)
Same as
WriteStream.end() but writes some data to the stream before ending. |
default Future<Void> |
ReadStream.pipeTo(WriteStream<T> dst)
Same as
ReadStream.pipeTo(WriteStream, Handler) but returns a Future of the asynchronous result |
default Future<Void> |
Pipe.to(WriteStream<T> dst)
Same as
Pipe.to(WriteStream, Handler) but returns a Future of the asynchronous result |
Future<Void> |
WriteStream.write(T data)
Write some data to the stream.
|
| Modifier and Type | Method and Description |
|---|---|
default Future<User> |
AuthProvider.authenticate(JsonObject authInfo)
Authenticate a user.
|
default Future<Boolean> |
User.isAuthorized(String authority)
Is the user authorised to
|
| Modifier and Type | Method and Description |
|---|---|
default Future<String> |
MongoAuth.insertUser(String username,
String password,
List<String> roles,
List<String> permissions)
Insert a new user into mongo in the convenient way
|
| Modifier and Type | Method and Description |
|---|---|
default Future<AccessToken> |
OAuth2Auth.decodeToken(String token)
Decode a token to a
AccessToken object. |
default Future<OAuth2Response> |
AccessToken.fetch(HttpMethod method,
String resource,
JsonObject headers,
Buffer payload)
Fetches a JSON resource using this Access Token.
|
default Future<OAuth2Response> |
AccessToken.fetch(String resource)
Fetches a JSON resource using this Access Token.
|
default Future<Void> |
AccessToken.introspect()
Introspect access token.
|
default Future<Void> |
AccessToken.introspect(String tokenType)
Introspect access token.
|
default Future<AccessToken> |
OAuth2Auth.introspectToken(String token)
Query an OAuth 2.0 authorization server to determine the active state of an OAuth 2.0 token and to determine
meta-information about this token.
|
default Future<Boolean> |
OAuth2RBAC.isAuthorized(AccessToken user,
String authority)
This method should verify if the user has the given authority and return either a boolean value or an error.
|
default Future<Void> |
OAuth2Auth.loadJWK()
Loads a JWK Set from the remote provider.
|
default Future<Void> |
AccessToken.logout()
Revoke refresh token and calls the logout endpoint.
|
default Future<Void> |
AccessToken.refresh()
Refresh the access token
|
default Future<Void> |
AccessToken.revoke(String token_type)
Revoke access or refresh token
|
default Future<JsonObject> |
AccessToken.userInfo()
Load the user info as per OIDC spec.
|
| Modifier and Type | Method and Description |
|---|---|
static Future<OAuth2Auth> |
SalesforceAuth.discover(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
GoogleAuth.discover(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
AzureADAuth.discover(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static Future<OAuth2Auth> |
KeycloakAuth.discover(Vertx vertx,
OAuth2ClientOptions config)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
ReactiveWriteStream.write(T data) |
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
RoutingContext.end()
Shortcut to the response end.
|
default Future<Void> |
RoutingContext.end(Buffer buffer)
Shortcut to the response end.
|
default Future<Void> |
RoutingContext.end(String chunk)
Shortcut to the response end.
|
default Future<Void> |
RoutingContext.json(Object json)
Encode an Object to JSON and end the request.
|
default Future<Void> |
RoutingContext.redirect(String url)
Perform a 302 redirect to
url. |
| Modifier and Type | Method and Description |
|---|---|
static Future<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.create(Vertx vertx,
String url) |
static Future<OpenAPI3RouterFactory> |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth) |
| Modifier and Type | Method and Description |
|---|---|
default Future<HttpResponse<T>> |
HttpRequest.send() |
default Future<HttpResponse<T>> |
HttpRequest.sendBuffer(Buffer body) |
default Future<HttpResponse<T>> |
HttpRequest.sendForm(MultiMap body) |
default Future<HttpResponse<T>> |
HttpRequest.sendJson(Object body) |
default Future<HttpResponse<T>> |
HttpRequest.sendJsonObject(JsonObject body) |
default Future<HttpResponse<T>> |
HttpRequest.sendMultipartForm(MultipartForm body) |
default Future<HttpResponse<T>> |
HttpRequest.sendStream(ReadStream<Buffer> body) |
| Modifier and Type | Method and Description |
|---|---|
Future<T> |
BodyStream.result() |
| Modifier and Type | Method and Description |
|---|---|
default Future<Buffer> |
TemplateEngine.render(JsonObject context,
String templateFileName) |
default Future<Buffer> |
TemplateEngine.render(Map<String,Object> context,
String templateFileName) |
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
AuthHandler.authorize(User user) |
default Future<JsonObject> |
AuthHandler.parseCredentials(RoutingContext context) |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
SockJSSocket.end()
Call
SockJSSocket.close(). |
default Future<Void> |
SockJSSocket.write(Buffer data) |
default Future<Void> |
SockJSSocket.write(String data)
Write a
String to the socket, encoded in UTF-8. |
| Modifier and Type | Method and Description |
|---|---|
default Future<Void> |
SessionStore.clear() |
default Future<Void> |
SessionStore.delete(String cookieValue) |
default Future<Session> |
SessionStore.get(String cookieValue) |
default Future<Void> |
SessionStore.put(Session session) |
default Future<Integer> |
SessionStore.size() |
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
VertxTestContext.assertComplete(Future<T> fut)
This method allows you to check if a future is completed.
|
<T> Future<T> |
VertxTestContext.assertFailure(Future<T> fut)
This method allows you to check if a future is failed.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Future<T> |
VertxTestContext.assertComplete(Future<T> fut)
This method allows you to check if a future is completed.
|
<T> Future<T> |
VertxTestContext.assertFailure(Future<T> fut)
This method allows you to check if a future is failed.
|
| Modifier and Type | Method and Description |
|---|---|
Future<HttpResponse<Buffer>> |
TestRequest.send(VertxTestContext testContext)
Send and complete test context with
VertxTestContext.completeNow() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.send(VertxTestContext testContext,
Checkpoint checkpoint)
Send and flag the provided checkpoint with
Checkpoint.flag() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.send(VertxTestContext testContext,
VertxTestContext.ExecutionBlock onEnd)
Send and execute
onEnd code block wrapped in VertxTestContext.verify(VertxTestContext.ExecutionBlock)
when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendBuffer(Buffer buf,
VertxTestContext testContext)
Send a
Buffer and complete test context with VertxTestContext.completeNow() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendBuffer(Buffer buf,
VertxTestContext testContext,
Checkpoint checkpoint)
Send a
Buffer and flag the provided checkpoint with Checkpoint.flag() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendBuffer(Buffer buf,
VertxTestContext testContext,
VertxTestContext.ExecutionBlock onEnd)
Send a
Buffer and execute onEnd code block wrapped in VertxTestContext.verify(VertxTestContext.ExecutionBlock)
when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendJson(Object json,
VertxTestContext testContext)
Send a json and complete test context with
VertxTestContext.completeNow() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendJson(Object json,
VertxTestContext testContext,
Checkpoint checkpoint)
Send a json and flag the provided checkpoint with
Checkpoint.flag() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendJson(Object json,
VertxTestContext testContext,
VertxTestContext.ExecutionBlock onEnd)
Send a json and execute
onEnd code block wrapped in VertxTestContext.verify(VertxTestContext.ExecutionBlock)
when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendMultipartForm(MultipartForm form,
VertxTestContext testContext)
Send a multipart form and complete test context with
VertxTestContext.completeNow() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendMultipartForm(MultipartForm form,
VertxTestContext testContext,
Checkpoint checkpoint)
Send a multipart form and flag the provided checkpoint with
Checkpoint.flag() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendMultipartForm(MultipartForm form,
VertxTestContext testContext,
VertxTestContext.ExecutionBlock onEnd)
Send a multipart form and execute
onEnd code block wrapped in VertxTestContext.verify(VertxTestContext.ExecutionBlock)
when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendURLEncodedForm(MultiMap form,
VertxTestContext testContext)
Send an URL Encoded form and complete test context with
VertxTestContext.completeNow() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendURLEncodedForm(MultiMap form,
VertxTestContext testContext,
Checkpoint checkpoint)
Send an URL Encoded form and flag the provided checkpoint with
Checkpoint.flag() when request is completed and no assertion fails |
Future<HttpResponse<Buffer>> |
TestRequest.sendURLEncodedForm(MultiMap form,
VertxTestContext testContext,
VertxTestContext.ExecutionBlock onEnd)
Send an URL Encoded form and execute
onEnd code block wrapped in VertxTestContext.verify(VertxTestContext.ExecutionBlock)
when request is completed and no assertion fails |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
KafkaAdminClient.alterConfigs(Map<ConfigResource,Config> configs)
Like
KafkaAdminClient.alterConfigs(Map, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaAdminClient.createTopics(List<NewTopic> topics)
Like
KafkaAdminClient.createTopics(List, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaAdminClient.deleteTopics(List<String> topicNames)
Like
KafkaAdminClient.deleteTopics(List, Handler) but returns a Future of the asynchronous result |
Future<Map<ConfigResource,Config>> |
KafkaAdminClient.describeConfigs(List<ConfigResource> configResources)
Like
KafkaAdminClient.describeConfigs(List, Handler) but returns a Future of the asynchronous result |
Future<Map<String,ConsumerGroupDescription>> |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds)
Like
KafkaAdminClient.describeConsumerGroups(List, Handler) but returns a Future of the asynchronous result |
Future<Map<String,TopicDescription>> |
KafkaAdminClient.describeTopics(List<String> topicNames)
Like
KafkaAdminClient.describeTopics(List, Handler) but returns a Future of the asynchronous result |
Future<List<ConsumerGroupListing>> |
KafkaAdminClient.listConsumerGroups()
Like
KafkaAdminClient.listConsumerGroups(Handler) but returns a Future of the asynchronous result |
Future<Set<String>> |
KafkaAdminClient.listTopics()
Like
KafkaAdminClient.listTopics(Handler) but returns a Future of the asynchronous result |
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
KafkaReadStream.assign(Set<org.apache.kafka.common.TopicPartition> partitions)
Manually assign a set of partitions to this consumer.
|
Future<Void> |
KafkaConsumer.assign(Set<TopicPartition> topicPartitions)
Manually assign a list of partition to this consumer.
|
Future<Void> |
KafkaConsumer.assign(TopicPartition topicPartition)
Manually assign a partition to this consumer.
|
Future<Set<org.apache.kafka.common.TopicPartition>> |
KafkaReadStream.assignment()
Like
KafkaReadStream.assignment(Handler) but returns a Future of the asynchronous result |
Future<Set<TopicPartition>> |
KafkaConsumer.assignment()
Like
KafkaConsumer.assignment(Handler) but returns a Future of the asynchronous result |
Future<Map<org.apache.kafka.common.TopicPartition,Long>> |
KafkaReadStream.beginningOffsets(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
Like
KafkaReadStream.beginningOffsets(Set, Handler) but returns a Future of the asynchronous result |
Future<Map<TopicPartition,Long>> |
KafkaConsumer.beginningOffsets(Set<TopicPartition> topicPartitions)
Like
KafkaConsumer.beginningOffsets(Set, Handler) but returns a Future of the asynchronous result |
Future<Long> |
KafkaReadStream.beginningOffsets(org.apache.kafka.common.TopicPartition topicPartition)
Like
KafkaReadStream.beginningOffsets(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Long> |
KafkaConsumer.beginningOffsets(TopicPartition topicPartition)
Like
KafkaConsumer.beginningOffsets(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaReadStream.close()
Close the stream
|
Future<Void> |
KafkaConsumer.close()
Close the consumer
|
Future<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>> |
KafkaReadStream.commit()
Commit current offsets for all the subscribed list of topics and partition.
|
Future<Void> |
KafkaConsumer.commit()
Commit current offsets for all the subscribed list of topics and partition.
|
Future<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>> |
KafkaReadStream.commit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
Future<Map<TopicPartition,OffsetAndMetadata>> |
KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
Future<org.apache.kafka.clients.consumer.OffsetAndMetadata> |
KafkaReadStream.committed(org.apache.kafka.common.TopicPartition topicPartition)
Like
KafkaReadStream.committed(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<OffsetAndMetadata> |
KafkaConsumer.committed(TopicPartition topicPartition)
Like
KafkaConsumer.committed(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Map<org.apache.kafka.common.TopicPartition,Long>> |
KafkaReadStream.endOffsets(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
Like
KafkaReadStream.endOffsets(Set, Handler) but returns a Future of the asynchronous result |
Future<Map<TopicPartition,Long>> |
KafkaConsumer.endOffsets(Set<TopicPartition> topicPartitions)
Like
KafkaConsumer.endOffsets(Set, Handler) but returns a Future of the asynchronous result |
Future<Long> |
KafkaReadStream.endOffsets(org.apache.kafka.common.TopicPartition topicPartition)
Like
KafkaReadStream.endOffsets(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Long> |
KafkaConsumer.endOffsets(TopicPartition topicPartition)
Like
KafkaConsumer.endOffsets(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Map<String,List<org.apache.kafka.common.PartitionInfo>>> |
KafkaReadStream.listTopics()
Like
KafkaReadStream.listTopics(Handler) but returns a Future of the asynchronous result |
Future<Map<String,List<PartitionInfo>>> |
KafkaConsumer.listTopics()
Like
KafkaConsumer.listTopics(Handler) but returns a Future of the asynchronous result |
Future<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndTimestamp>> |
KafkaReadStream.offsetsForTimes(Map<org.apache.kafka.common.TopicPartition,Long> topicPartitionTimestamps)
Like
KafkaReadStream.offsetsForTimes(Map, Handler) but returns a Future of the asynchronous result |
Future<Map<TopicPartition,OffsetAndTimestamp>> |
KafkaConsumer.offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps)
Like
KafkaConsumer.offsetsForTimes(Map, Handler) but returns a Future of the asynchronous result |
Future<org.apache.kafka.clients.consumer.OffsetAndTimestamp> |
KafkaReadStream.offsetsForTimes(org.apache.kafka.common.TopicPartition topicPartition,
long timestamp)
Like
KafkaReadStream.offsetsForTimes(TopicPartition, long, Handler) but returns a Future of the asynchronous result |
Future<OffsetAndTimestamp> |
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
Long timestamp)
Like
KafkaConsumer.offsetsForTimes(TopicPartition, Long, Handler) but returns a Future of the asynchronous result |
Future<List<org.apache.kafka.common.PartitionInfo>> |
KafkaReadStream.partitionsFor(String topic)
Like
KafkaReadStream.partitionsFor(String, Handler) but returns a Future of the asynchronous result |
Future<List<PartitionInfo>> |
KafkaConsumer.partitionsFor(String topic)
Like
KafkaConsumer.partitionsFor(String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaReadStream.pause(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
Suspend fetching from the requested partitions.
|
Future<Void> |
KafkaConsumer.pause(Set<TopicPartition> topicPartitions)
Suspend fetching from the requested partitions.
|
Future<Void> |
KafkaConsumer.pause(TopicPartition topicPartition)
Suspend fetching from the requested partition.
|
Future<Set<org.apache.kafka.common.TopicPartition>> |
KafkaReadStream.paused()
Like
KafkaReadStream.paused(Handler) but returns a Future of the asynchronous result |
Future<Set<TopicPartition>> |
KafkaConsumer.paused()
Like
KafkaConsumer.paused(Handler) but returns a Future of the asynchronous result |
Future<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>> |
KafkaReadStream.poll(long timeout)
Like
KafkaReadStream.poll(long, Handler) but returns a Future of the asynchronous result |
Future<KafkaConsumerRecords<K,V>> |
KafkaConsumer.poll(long timeout)
Like
KafkaConsumer.poll(long, Handler) but returns a Future of the asynchronous result |
Future<Long> |
KafkaReadStream.position(org.apache.kafka.common.TopicPartition partition)
Like
KafkaReadStream.position(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Long> |
KafkaConsumer.position(TopicPartition partition)
Like
KafkaConsumer.position(TopicPartition, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaReadStream.resume(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
Resume specified partitions which have been paused with pause.
|
Future<Void> |
KafkaConsumer.resume(Set<TopicPartition> topicPartitions)
Resume specified partitions which have been paused with pause.
|
Future<Void> |
KafkaConsumer.resume(TopicPartition topicPartition)
Resume specified partition which have been paused with pause.
|
Future<Void> |
KafkaReadStream.seek(org.apache.kafka.common.TopicPartition topicPartition,
long offset)
Overrides the fetch offsets that the consumer will use on the next poll.
|
Future<Void> |
KafkaConsumer.seek(TopicPartition topicPartition,
long offset)
Overrides the fetch offsets that the consumer will use on the next poll.
|
Future<Void> |
KafkaReadStream.seekToBeginning(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
Seek to the first offset for each of the given partitions.
|
Future<Void> |
KafkaConsumer.seekToBeginning(Set<TopicPartition> topicPartitions)
Seek to the first offset for each of the given partitions.
|
Future<Void> |
KafkaConsumer.seekToBeginning(TopicPartition topicPartition)
Seek to the first offset for each of the given partition.
|
Future<Void> |
KafkaReadStream.seekToEnd(Set<org.apache.kafka.common.TopicPartition> topicPartitions)
Seek to the last offset for each of the given partitions.
|
Future<Void> |
KafkaConsumer.seekToEnd(Set<TopicPartition> topicPartitions)
Seek to the last offset for each of the given partitions.
|
Future<Void> |
KafkaConsumer.seekToEnd(TopicPartition topicPartition)
Seek to the last offset for each of the given partition.
|
Future<Void> |
KafkaReadStream.subscribe(Pattern pattern)
Subscribe to all topics matching specified pattern to get dynamically assigned partitions.
|
Future<Void> |
KafkaConsumer.subscribe(Pattern pattern)
Subscribe to all topics matching specified pattern to get dynamically assigned partitions.
|
Future<Void> |
KafkaReadStream.subscribe(Set<String> topics)
Subscribe to the given list of topics to get dynamically assigned partitions.
|
Future<Void> |
KafkaConsumer.subscribe(Set<String> topics)
Subscribe to the given list of topics to get dynamically assigned partitions.
|
Future<Void> |
KafkaConsumer.subscribe(String topic)
Subscribe to the given topic to get dynamically assigned partitions.
|
Future<Set<String>> |
KafkaReadStream.subscription()
Like
KafkaReadStream.subscription(Handler) but returns a Future of the asynchronous result |
Future<Set<String>> |
KafkaConsumer.subscription()
Like
KafkaConsumer.subscription(Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaReadStream.unsubscribe()
Unsubscribe from topics currently subscribed with subscribe.
|
Future<Void> |
KafkaConsumer.unsubscribe()
Unsubscribe from topics currently subscribed with subscribe.
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
KafkaProducer.close()
Close the producer
|
Future<Void> |
KafkaWriteStream.close()
Close the stream
|
Future<Void> |
KafkaProducer.close(long timeout)
Like
KafkaProducer.close(long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaWriteStream.close(long timeout)
Like
KafkaWriteStream.close(long, Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaProducer.flush()
Like
KafkaProducer.flush(Handler) but returns a Future of the asynchronous result |
Future<Void> |
KafkaWriteStream.flush()
Like
KafkaWriteStream.flush(Handler) but returns a Future of the asynchronous result |
Future<List<PartitionInfo>> |
KafkaProducer.partitionsFor(String topic)
Like
KafkaProducer.partitionsFor(String, Handler) but returns a Future of the asynchronous result |
Future<List<org.apache.kafka.common.PartitionInfo>> |
KafkaWriteStream.partitionsFor(String topic)
Like
KafkaWriteStream.partitionsFor(String, Handler) but returns a Future of the asynchronous result |
Future<RecordMetadata> |
KafkaProducer.send(KafkaProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
Future<org.apache.kafka.clients.producer.RecordMetadata> |
KafkaWriteStream.send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record)
Asynchronously write a record to a topic
|
| Modifier and Type | Method and Description |
|---|---|
Future<Void> |
MqttServer.close()
Close the server.
|
Future<MqttConnAckMessage> |
MqttClient.connect(int port,
String host)
Like
MqttClient.connect(int, String, Handler) but returns a Future of the asynchronous result |
Future<MqttConnAckMessage> |
MqttClient.connect(int port,
String host,
String serverName)
Like
MqttClient.connect(int, String, String, Handler) but returns a Future of the asynchronous result |
Future<Void> |
MqttClient.disconnect()
Disconnects from the MQTT server
|
Future<MqttServer> |
MqttServer.listen()
Start the server listening for incoming connections using the specified options
through the constructor
|
Future<MqttServer> |
MqttServer.listen(int port)
Start the server listening for incoming connections on the port specified but on
"0.0.0.0" as host.
|
Future<MqttServer> |
MqttServer.listen(int port,
String host)
Start the server listening for incoming connections on the port and host specified
|
Future<Integer> |
MqttClient.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT server
|
Future<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain)
Sends the PUBLISH message to the remote MQTT client
|
Future<Integer> |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId)
Like
MqttEndpoint.publish(String, Buffer, MqttQoS, boolean, boolean, int, Handler) but returns a Future of the asynchronous result |
Future<Integer> |
MqttClient.subscribe(Map<String,Integer> topics)
Subscribes to the topics with related QoS levels
|
Future<Integer> |
MqttClient.subscribe(String topic,
int qos)
Subscribes to the topic with a specified QoS level
|
Future<Integer> |
MqttClient.unsubscribe(String topic)
Unsubscribe from receiving messages on given topic
|
| Modifier and Type | Method and Description |
|---|---|
Future |
Future.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Future<T> |
Future.newInstance(Future arg) |
static <T> Future<T> |
Future.newInstance(Future arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Future(Future delegate) |
Future(Future delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
| Modifier and Type | Method and Description |
|---|---|
default Future<Response> |
RedisAPI.append(String arg0,
String arg1)
Redis command append.
|
default Future<Response> |
RedisAPI.asking()
Redis command asking.
|
default Future<Response> |
RedisAPI.auth(String arg0)
Redis command auth.
|
default Future<List<Response>> |
RedisConnection.batch(List<Request> commands)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
default Future<Response> |
RedisAPI.bgrewriteaof()
Redis command bgrewriteaof.
|
default Future<Response> |
RedisAPI.bgsave(List<String> args)
Redis command bgsave.
|
default Future<Response> |
RedisAPI.bitcount(List<String> args)
Redis command bitcount.
|
default Future<Response> |
RedisAPI.bitfield(List<String> args)
Redis command bitfield.
|
default Future<Response> |
RedisAPI.bitop(List<String> args)
Redis command bitop.
|
default Future<Response> |
RedisAPI.bitpos(List<String> args)
Redis command bitpos.
|
default Future<Response> |
RedisAPI.blpop(List<String> args)
Redis command blpop.
|
default Future<Response> |
RedisAPI.brpop(List<String> args)
Redis command brpop.
|
default Future<Response> |
RedisAPI.brpoplpush(String arg0,
String arg1,
String arg2)
Redis command brpoplpush.
|
default Future<Response> |
RedisAPI.bzpopmax(List<String> args)
Redis command bzpopmax.
|
default Future<Response> |
RedisAPI.bzpopmin(List<String> args)
Redis command bzpopmin.
|
default Future<Response> |
RedisAPI.client(List<String> args)
Redis command client.
|
default Future<Response> |
RedisAPI.cluster(List<String> args)
Redis command cluster.
|
default Future<Response> |
RedisAPI.command()
Redis command command.
|
default Future<Response> |
RedisAPI.config(List<String> args)
Redis command config.
|
default Future<RedisConnection> |
Redis.connect()
Connects to the redis server.
|
default Future<Response> |
RedisAPI.dbsize()
Redis command dbsize.
|
default Future<Response> |
RedisAPI.debug(List<String> args)
Redis command debug.
|
default Future<Response> |
RedisAPI.decr(String arg0)
Redis command decr.
|
default Future<Response> |
RedisAPI.decrby(String arg0,
String arg1)
Redis command decrby.
|
default Future<Response> |
RedisAPI.del(List<String> args)
Redis command del.
|
default Future<Response> |
RedisAPI.discard()
Redis command discard.
|
default Future<Response> |
RedisAPI.dump(String arg0)
Redis command dump.
|
default Future<Response> |
RedisAPI.echo(String arg0)
Redis command echo.
|
default Future<Response> |
RedisAPI.eval(List<String> args)
Redis command eval.
|
default Future<Response> |
RedisAPI.evalsha(List<String> args)
Redis command evalsha.
|
default Future<Response> |
RedisAPI.exec()
Redis command exec.
|
default Future<Response> |
RedisAPI.exists(List<String> args)
Redis command exists.
|
default Future<Response> |
RedisAPI.expire(String arg0,
String arg1)
Redis command expire.
|
default Future<Response> |
RedisAPI.expireat(String arg0,
String arg1)
Redis command expireat.
|
default Future<Response> |
RedisAPI.flushall(List<String> args)
Redis command flushall.
|
default Future<Response> |
RedisAPI.flushdb(List<String> args)
Redis command flushdb.
|
default Future<Response> |
RedisAPI.geoadd(List<String> args)
Redis command geoadd.
|
default Future<Response> |
RedisAPI.geodist(List<String> args)
Redis command geodist.
|
default Future<Response> |
RedisAPI.geohash(List<String> args)
Redis command geohash.
|
default Future<Response> |
RedisAPI.geopos(List<String> args)
Redis command geopos.
|
default Future<Response> |
RedisAPI.georadius(List<String> args)
Redis command georadius.
|
default Future<Response> |
RedisAPI.georadiusbymember(List<String> args)
Redis command georadiusbymember.
|
default Future<Response> |
RedisAPI.georadiusbymemberRo(List<String> args)
Redis command georadiusbymemberRo.
|
default Future<Response> |
RedisAPI.georadiusRo(List<String> args)
Redis command georadiusRo.
|
default Future<Response> |
RedisAPI.get(String arg0)
Redis command get.
|
default Future<Response> |
RedisAPI.getbit(String arg0,
String arg1)
Redis command getbit.
|
default Future<Response> |
RedisAPI.getrange(String arg0,
String arg1,
String arg2)
Redis command getrange.
|
default Future<Response> |
RedisAPI.getset(String arg0,
String arg1)
Redis command getset.
|
default Future<Response> |
RedisAPI.hdel(List<String> args)
Redis command hdel.
|
default Future<Response> |
RedisAPI.hexists(String arg0,
String arg1)
Redis command hexists.
|
default Future<Response> |
RedisAPI.hget(String arg0,
String arg1)
Redis command hget.
|
default Future<Response> |
RedisAPI.hgetall(String arg0)
Redis command hgetall.
|
default Future<Response> |
RedisAPI.hincrby(String arg0,
String arg1,
String arg2)
Redis command hincrby.
|
default Future<Response> |
RedisAPI.hincrbyfloat(String arg0,
String arg1,
String arg2)
Redis command hincrbyfloat.
|
default Future<Response> |
RedisAPI.hkeys(String arg0)
Redis command hkeys.
|
default Future<Response> |
RedisAPI.hlen(String arg0)
Redis command hlen.
|
default Future<Response> |
RedisAPI.hmget(List<String> args)
Redis command hmget.
|
default Future<Response> |
RedisAPI.hmset(List<String> args)
Redis command hmset.
|
default Future<Response> |
RedisAPI.host(List<String> args)
Redis command host.
|
default Future<Response> |
RedisAPI.hscan(List<String> args)
Redis command hscan.
|
default Future<Response> |
RedisAPI.hset(List<String> args)
Redis command hset.
|
default Future<Response> |
RedisAPI.hsetnx(String arg0,
String arg1,
String arg2)
Redis command hsetnx.
|
default Future<Response> |
RedisAPI.hstrlen(String arg0,
String arg1)
Redis command hstrlen.
|
default Future<Response> |
RedisAPI.hvals(String arg0)
Redis command hvals.
|
default Future<Response> |
RedisAPI.incr(String arg0)
Redis command incr.
|
default Future<Response> |
RedisAPI.incrby(String arg0,
String arg1)
Redis command incrby.
|
default Future<Response> |
RedisAPI.incrbyfloat(String arg0,
String arg1)
Redis command incrbyfloat.
|
default Future<Response> |
RedisAPI.info(List<String> args)
Redis command info.
|
default Future<Response> |
RedisAPI.keys(String arg0)
Redis command keys.
|
default Future<Response> |
RedisAPI.lastsave()
Redis command lastsave.
|
default Future<Response> |
RedisAPI.latency(List<String> args)
Redis command latency.
|
default Future<Response> |
RedisAPI.lindex(String arg0,
String arg1)
Redis command lindex.
|
default Future<Response> |
RedisAPI.linsert(String arg0,
String arg1,
String arg2,
String arg3)
Redis command linsert.
|
default Future<Response> |
RedisAPI.llen(String arg0)
Redis command llen.
|
default Future<Response> |
RedisAPI.lolwut(List<String> args)
Redis command lolwut.
|
default Future<Response> |
RedisAPI.lpop(String arg0)
Redis command lpop.
|
default Future<Response> |
RedisAPI.lpush(List<String> args)
Redis command lpush.
|
default Future<Response> |
RedisAPI.lpushx(List<String> args)
Redis command lpushx.
|
default Future<Response> |
RedisAPI.lrange(String arg0,
String arg1,
String arg2)
Redis command lrange.
|
default Future<Response> |
RedisAPI.lrem(String arg0,
String arg1,
String arg2)
Redis command lrem.
|
default Future<Response> |
RedisAPI.lset(String arg0,
String arg1,
String arg2)
Redis command lset.
|
default Future<Response> |
RedisAPI.ltrim(String arg0,
String arg1,
String arg2)
Redis command ltrim.
|
default Future<Response> |
RedisAPI.memory(List<String> args)
Redis command memory.
|
default Future<Response> |
RedisAPI.mget(List<String> args)
Redis command mget.
|
default Future<Response> |
RedisAPI.migrate(List<String> args)
Redis command migrate.
|
default Future<Response> |
RedisAPI.module(List<String> args)
Redis command module.
|
default Future<Response> |
RedisAPI.monitor()
Redis command monitor.
|
default Future<Response> |
RedisAPI.move(String arg0,
String arg1)
Redis command move.
|
default Future<Response> |
RedisAPI.mset(List<String> args)
Redis command mset.
|
default Future<Response> |
RedisAPI.msetnx(List<String> args)
Redis command msetnx.
|
default Future<Response> |
RedisAPI.multi()
Redis command multi.
|
default Future<Response> |
RedisAPI.object(List<String> args)
Redis command object.
|
default Future<Response> |
RedisAPI.persist(String arg0)
Redis command persist.
|
default Future<Response> |
RedisAPI.pexpire(String arg0,
String arg1)
Redis command pexpire.
|
default Future<Response> |
RedisAPI.pexpireat(String arg0,
String arg1)
Redis command pexpireat.
|
default Future<Response> |
RedisAPI.pfadd(List<String> args)
Redis command pfadd.
|
default Future<Response> |
RedisAPI.pfcount(List<String> args)
Redis command pfcount.
|
default Future<Response> |
RedisAPI.pfdebug(List<String> args)
Redis command pfdebug.
|
default Future<Response> |
RedisAPI.pfmerge(List<String> args)
Redis command pfmerge.
|
default Future<Response> |
RedisAPI.pfselftest()
Redis command pfselftest.
|
default Future<Response> |
RedisAPI.ping(List<String> args)
Redis command ping.
|
default Future<Response> |
RedisAPI.post(List<String> args)
Redis command post.
|
default Future<Response> |
RedisAPI.psetex(String arg0,
String arg1,
String arg2)
Redis command psetex.
|
default Future<Response> |
RedisAPI.psubscribe(List<String> args)
Redis command psubscribe.
|
default Future<Response> |
RedisAPI.psync(String arg0,
String arg1)
Redis command psync.
|
default Future<Response> |
RedisAPI.pttl(String arg0)
Redis command pttl.
|
default Future<Response> |
RedisAPI.publish(String arg0,
String arg1)
Redis command publish.
|
default Future<Response> |
RedisAPI.pubsub(List<String> args)
Redis command pubsub.
|
default Future<Response> |
RedisAPI.punsubscribe(List<String> args)
Redis command punsubscribe.
|
default Future<Response> |
RedisAPI.randomkey()
Redis command randomkey.
|
default Future<Response> |
RedisAPI.readonly()
Redis command readonly.
|
default Future<Response> |
RedisAPI.readwrite()
Redis command readwrite.
|
default Future<Response> |
RedisAPI.rename(String arg0,
String arg1)
Redis command rename.
|
default Future<Response> |
RedisAPI.renamenx(String arg0,
String arg1)
Redis command renamenx.
|
default Future<Response> |
RedisAPI.replconf(List<String> args)
Redis command replconf.
|
default Future<Response> |
RedisAPI.replicaof(String arg0,
String arg1)
Redis command replicaof.
|
default Future<Response> |
RedisAPI.restore(List<String> args)
Redis command restore.
|
default Future<Response> |
RedisAPI.restoreAsking(List<String> args)
Redis command restoreAsking.
|
default Future<Response> |
RedisAPI.role()
Redis command role.
|
default Future<Response> |
RedisAPI.rpop(String arg0)
Redis command rpop.
|
default Future<Response> |
RedisAPI.rpoplpush(String arg0,
String arg1)
Redis command rpoplpush.
|
default Future<Response> |
RedisAPI.rpush(List<String> args)
Redis command rpush.
|
default Future<Response> |
RedisAPI.rpushx(List<String> args)
Redis command rpushx.
|
default Future<Response> |
RedisAPI.sadd(List<String> args)
Redis command sadd.
|
default Future<Response> |
RedisAPI.save()
Redis command save.
|
default Future<Response> |
RedisAPI.scan(List<String> args)
Redis command scan.
|
default Future<Response> |
RedisAPI.scard(String arg0)
Redis command scard.
|
default Future<Response> |
RedisAPI.script(List<String> args)
Redis command script.
|
default Future<Response> |
RedisAPI.sdiff(List<String> args)
Redis command sdiff.
|
default Future<Response> |
RedisAPI.sdiffstore(List<String> args)
Redis command sdiffstore.
|
default Future<Response> |
RedisAPI.select(String arg0)
Redis command select.
|
Future<Response> |
RedisAPI.send(Command cmd,
String... args)
Send untyped command to redis.
|
default Future<Response> |
RedisConnection.send(Request command)
Send the given command to the redis server or cluster.
|
default Future<Response> |
RedisAPI.set(List<String> args)
Redis command set.
|
default Future<Response> |
RedisAPI.setbit(String arg0,
String arg1,
String arg2)
Redis command setbit.
|
default Future<Response> |
RedisAPI.setex(String arg0,
String arg1,
String arg2)
Redis command setex.
|
default Future<Response> |
RedisAPI.setnx(String arg0,
String arg1)
Redis command setnx.
|
default Future<Response> |
RedisAPI.setrange(String arg0,
String arg1,
String arg2)
Redis command setrange.
|
default Future<Response> |
RedisAPI.shutdown(List<String> args)
Redis command shutdown.
|
default Future<Response> |
RedisAPI.sinter(List<String> args)
Redis command sinter.
|
default Future<Response> |
RedisAPI.sinterstore(List<String> args)
Redis command sinterstore.
|
default Future<Response> |
RedisAPI.sismember(String arg0,
String arg1)
Redis command sismember.
|
default Future<Response> |
RedisAPI.slaveof(String arg0,
String arg1)
Redis command slaveof.
|
default Future<Response> |
RedisAPI.slowlog(List<String> args)
Redis command slowlog.
|
default Future<Response> |
RedisAPI.smembers(String arg0)
Redis command smembers.
|
default Future<Response> |
RedisAPI.smove(String arg0,
String arg1,
String arg2)
Redis command smove.
|
default Future<Response> |
RedisAPI.sort(List<String> args)
Redis command sort.
|
default Future<Response> |
RedisAPI.spop(List<String> args)
Redis command spop.
|
default Future<Response> |
RedisAPI.srandmember(List<String> args)
Redis command srandmember.
|
default Future<Response> |
RedisAPI.srem(List<String> args)
Redis command srem.
|
default Future<Response> |
RedisAPI.sscan(List<String> args)
Redis command sscan.
|
default Future<Response> |
RedisAPI.strlen(String arg0)
Redis command strlen.
|
default Future<Response> |
RedisAPI.subscribe(List<String> args)
Redis command subscribe.
|
default Future<Response> |
RedisAPI.substr(String arg0,
String arg1,
String arg2)
Redis command substr.
|
default Future<Response> |
RedisAPI.sunion(List<String> args)
Redis command sunion.
|
default Future<Response> |
RedisAPI.sunionstore(List<String> args)
Redis command sunionstore.
|
default Future<Response> |
RedisAPI.swapdb(String arg0,
String arg1)
Redis command swapdb.
|
default Future<Response> |
RedisAPI.sync()
Redis command sync.
|
default Future<Response> |
RedisAPI.time()
Redis command time.
|
default Future<Response> |
RedisAPI.touch(List<String> args)
Redis command touch.
|
default Future<Response> |
RedisAPI.ttl(String arg0)
Redis command ttl.
|
default Future<Response> |
RedisAPI.type(String arg0)
Redis command type.
|
default Future<Response> |
RedisAPI.unlink(List<String> args)
Redis command unlink.
|
default Future<Response> |
RedisAPI.unsubscribe(List<String> args)
Redis command unsubscribe.
|
default Future<Response> |
RedisAPI.unwatch()
Redis command unwatch.
|
default Future<Response> |
RedisAPI.wait(String arg0,
String arg1)
Redis command wait.
|
default Future<Response> |
RedisAPI.watch(List<String> args)
Redis command watch.
|
default Future<Response> |
RedisAPI.xack(List<String> args)
Redis command xack.
|
default Future<Response> |
RedisAPI.xadd(List<String> args)
Redis command xadd.
|
default Future<Response> |
RedisAPI.xclaim(List<String> args)
Redis command xclaim.
|
default Future<Response> |
RedisAPI.xdel(List<String> args)
Redis command xdel.
|
default Future<Response> |
RedisAPI.xgroup(List<String> args)
Redis command xgroup.
|
default Future<Response> |
RedisAPI.xinfo(List<String> args)
Redis command xinfo.
|
default Future<Response> |
RedisAPI.xlen(String arg0)
Redis command xlen.
|
default Future<Response> |
RedisAPI.xpending(List<String> args)
Redis command xpending.
|
default Future<Response> |
RedisAPI.xrange(List<String> args)
Redis command xrange.
|
default Future<Response> |
RedisAPI.xread(List<String> args)
Redis command xread.
|
default Future<Response> |
RedisAPI.xreadgroup(List<String> args)
Redis command xreadgroup.
|
default Future<Response> |
RedisAPI.xrevrange(List<String> args)
Redis command xrevrange.
|
default Future<Response> |
RedisAPI.xsetid(String arg0,
String arg1)
Redis command xsetid.
|
default Future<Response> |
RedisAPI.xtrim(List<String> args)
Redis command xtrim.
|
default Future<Response> |
RedisAPI.zadd(List<String> args)
Redis command zadd.
|
default Future<Response> |
RedisAPI.zcard(String arg0)
Redis command zcard.
|
default Future<Response> |
RedisAPI.zcount(String arg0,
String arg1,
String arg2)
Redis command zcount.
|
default Future<Response> |
RedisAPI.zincrby(String arg0,
String arg1,
String arg2)
Redis command zincrby.
|
default Future<Response> |
RedisAPI.zinterstore(List<String> args)
Redis command zinterstore.
|
default Future<Response> |
RedisAPI.zlexcount(String arg0,
String arg1,
String arg2)
Redis command zlexcount.
|
default Future<Response> |
RedisAPI.zpopmax(List<String> args)
Redis command zpopmax.
|
default Future<Response> |
RedisAPI.zpopmin(List<String> args)
Redis command zpopmin.
|
default Future<Response> |
RedisAPI.zrange(List<String> args)
Redis command zrange.
|
default Future<Response> |
RedisAPI.zrangebylex(List<String> args)
Redis command zrangebylex.
|
default Future<Response> |
RedisAPI.zrangebyscore(List<String> args)
Redis command zrangebyscore.
|
default Future<Response> |
RedisAPI.zrank(String arg0,
String arg1)
Redis command zrank.
|
default Future<Response> |
RedisAPI.zrem(List<String> args)
Redis command zrem.
|
default Future<Response> |
RedisAPI.zremrangebylex(String arg0,
String arg1,
String arg2)
Redis command zremrangebylex.
|
default Future<Response> |
RedisAPI.zremrangebyrank(String arg0,
String arg1,
String arg2)
Redis command zremrangebyrank.
|
default Future<Response> |
RedisAPI.zremrangebyscore(String arg0,
String arg1,
String arg2)
Redis command zremrangebyscore.
|
default Future<Response> |
RedisAPI.zrevrange(List<String> args)
Redis command zrevrange.
|
default Future<Response> |
RedisAPI.zrevrangebylex(List<String> args)
Redis command zrevrangebylex.
|
default Future<Response> |
RedisAPI.zrevrangebyscore(List<String> args)
Redis command zrevrangebyscore.
|
default Future<Response> |
RedisAPI.zrevrank(String arg0,
String arg1)
Redis command zrevrank.
|
default Future<Response> |
RedisAPI.zscan(List<String> args)
Redis command zscan.
|
default Future<Response> |
RedisAPI.zscore(String arg0,
String arg1)
Redis command zscore.
|
default Future<Response> |
RedisAPI.zunionstore(List<String> args)
Redis command zunionstore.
|
| Modifier and Type | Method and Description |
|---|---|
Future |
Future.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static <T> Future<T> |
Future.newInstance(Future arg) |
static <T> Future<T> |
Future.newInstance(Future arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
| Constructor and Description |
|---|
Future(Future delegate) |
Future(Future delegate,
io.vertx.lang.rx.TypeArg<T> typeArg_0) |
| Modifier and Type | Method and Description |
|---|---|
Future<Message<JsonObject>> |
ServiceJWTInterceptor.apply(Message<JsonObject> msg) |
| Modifier and Type | Method and Description |
|---|---|
ServiceBinder |
ServiceBinder.addInterceptor(java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>> interceptor) |
MessageConsumer<JsonObject> |
ProxyHandler.register(EventBus eventBus,
String address,
List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors)
Register the proxy handle on the event bus.
|
MessageConsumer<JsonObject> |
ProxyHandler.registerLocal(EventBus eventBus,
String address,
List<java.util.function.Function<Message<JsonObject>,Future<Message<JsonObject>>>> interceptors)
Register the local proxy handle on the event bus.
|
Copyright © 2019 Eclipse. All rights reserved.