| Modifier and Type | Method and Description |
|---|---|
AmqpConnection |
AmqpConnection.close(Handler<AsyncResult<Void>> done)
Closes the AMQP connection, i.e.
|
void |
AmqpSender.close(Handler<AsyncResult<Void>> handler)
Closes the sender.
|
void |
AmqpReceiver.close(Handler<AsyncResult<Void>> handler)
Closes the receiver.
|
AmqpClient |
AmqpClient.connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
Connects to the AMQP broker or router.
|
AmqpConnection |
AmqpConnection.createAnonymousSender(Handler<AsyncResult<AmqpSender>> completionHandler)
Creates an anonymous sender.
|
AmqpConnection |
AmqpConnection.createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a dynamic receiver.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpClient |
AmqpClient.createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpClient |
AmqpClient.createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpConnection |
AmqpConnection.createSender(String address,
AmqpSenderOptions options,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpClient |
AmqpClient.createSender(String address,
AmqpSenderOptions options,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpConnection |
AmqpConnection.createSender(String address,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpClient |
AmqpClient.createSender(String address,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpSender |
AmqpSender.sendWithAck(AmqpMessage message,
Handler<AsyncResult<Void>> acknowledgementHandler)
Sends an AMQP message and waits for an acknowledgement.
|
AmqpSender |
AmqpSender.write(AmqpMessage data,
Handler<AsyncResult<Void>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
AmqpBridge.close(Handler<AsyncResult<Void>> resultHandler)
Shuts the bridge down, closing the underlying connection.
|
void |
AmqpBridge.start(String hostname,
int port,
Handler<AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
void |
AmqpBridge.start(String hostname,
int port,
String username,
String password,
Handler<AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
| Modifier and Type | Method and Description |
|---|---|
CamelBridge |
CamelBridge.start(Handler<AsyncResult<Void>> completed)
Starts the bridge.
|
CamelBridge |
CamelBridge.stop(Handler<AsyncResult<Void>> completed)
Stops the bridge.
|
| Modifier and Type | Method and Description |
|---|---|
ResultSet |
ResultSet.all(Handler<AsyncResult<List<com.datastax.driver.core.Row>>> handler)
The method should not be used concurrently with others like
ResultSet.several(int, Handler) or ResultSet.one(Handler). |
CassandraClient |
CassandraClient.close(Handler<AsyncResult<Void>> closeHandler)
Closes this client.
|
void |
Mapper.delete(List<Object> primaryKey,
Handler<AsyncResult<Void>> handler)
Asynchronous delete method based on the column values of the primary key.
|
<R> CassandraClient |
CassandraClient.execute(com.datastax.driver.core.Statement statement,
java.util.stream.Collector<com.datastax.driver.core.Row,?,R> collector,
Handler<AsyncResult<R>> resultHandler)
Execute a statement and produce a result by applying a collector to result set rows.
|
CassandraClient |
CassandraClient.execute(com.datastax.driver.core.Statement statement,
Handler<AsyncResult<ResultSet>> resultHandler)
Execute the statement and provide a handler for consuming results.
|
<R> CassandraClient |
CassandraClient.execute(String query,
java.util.stream.Collector<com.datastax.driver.core.Row,?,R> collector,
Handler<AsyncResult<R>> resultHandler)
Execute a query and produce a result by applying a collector to result set rows.
|
CassandraClient |
CassandraClient.execute(String query,
Handler<AsyncResult<ResultSet>> resultHandler)
Execute the query and provide a handler for consuming results.
|
CassandraClient |
CassandraClient.executeWithFullFetch(com.datastax.driver.core.Statement statement,
Handler<AsyncResult<List<com.datastax.driver.core.Row>>> resultHandler)
Execute the query and provide a handler for consuming results.
|
CassandraClient |
CassandraClient.executeWithFullFetch(String query,
Handler<AsyncResult<List<com.datastax.driver.core.Row>>> resultHandler)
Execute the query and provide a handler for consuming results.
|
ResultSet |
ResultSet.fetchMoreResults(Handler<AsyncResult<Void>> handler) |
void |
Mapper.get(List<Object> primaryKey,
Handler<AsyncResult<T>> handler)
Asynchronous get method based on the column values of the primary key.
|
ResultSet |
ResultSet.one(Handler<AsyncResult<com.datastax.driver.core.Row>> handler)
The method should not be used concurrently with others like
ResultSet.several(int, Handler) or ResultSet.all(Handler). |
CassandraClient |
CassandraClient.prepare(String query,
Handler<AsyncResult<com.datastax.driver.core.PreparedStatement>> resultHandler)
Prepares the provided query string.
|
CassandraClient |
CassandraClient.queryStream(com.datastax.driver.core.Statement statement,
Handler<AsyncResult<CassandraRowStream>> rowStreamHandler)
Executes the given SQL statement which returns the results of the query as a read stream.
|
CassandraClient |
CassandraClient.queryStream(String sql,
Handler<AsyncResult<CassandraRowStream>> rowStreamHandler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
void |
Mapper.save(T entity,
Handler<AsyncResult<Void>> handler)
Asynchronous save method.
|
ResultSet |
ResultSet.several(int amount,
Handler<AsyncResult<List<com.datastax.driver.core.Row>>> handler)
Fetch a specific amount of rows and notify via a handler.
|
| Modifier and Type | Method and Description |
|---|---|
default <T> void |
CircuitBreaker.execute(Handler<Promise<T>> command,
Handler<AsyncResult<T>> handler)
Same as
CircuitBreaker.executeWithFallback(Handler, Function) but using the circuit breaker default fallback. |
default <T> void |
CircuitBreaker.executeCommand(Handler<Promise<T>> command,
Handler<AsyncResult<T>> handler)
Deprecated.
instead use
CircuitBreaker.execute(Handler, Handler) |
default <T> void |
CircuitBreaker.executeCommandWithFallback(Handler<Promise<T>> command,
java.util.function.Function<Throwable,T> fallback,
Handler<AsyncResult<T>> handler)
Deprecated.
|
default <T> void |
CircuitBreaker.executeWithFallback(Handler<Promise<T>> command,
java.util.function.Function<Throwable,T> fallback,
Handler<AsyncResult<T>> handler)
Same as
CircuitBreaker.executeWithFallback(Handler, Function) but using a callback. |
| Modifier and Type | Method and Description |
|---|---|
void |
ConfigRetriever.getConfig(Handler<AsyncResult<JsonObject>> completionHandler)
Reads the configuration from the different
ConfigStore
and computes the final configuration. |
| Modifier and Type | Method and Description |
|---|---|
void |
ConsulConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
GitConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
HoconProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
ConfigMapStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
RedisConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
ConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler)
Retrieves the configuration store in this store.
|
void |
ConfigProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler)
Transforms the given
input into a JsonObject. |
| Modifier and Type | Method and Description |
|---|---|
void |
FileSet.buildConfiguration(List<File> files,
Handler<AsyncResult<JsonObject>> handler)
Iterates over the given set of files, and for each matching file, computes the resulting configuration.
|
| Modifier and Type | Method and Description |
|---|---|
void |
VaultConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
static <T> AsyncResult<T> |
VaultException.toFailure(String message) |
static <T> AsyncResult<T> |
VaultException.toFailure(String status,
int code,
String body) |
static <T> AsyncResult<T> |
VaultException.toFailure(String message,
Throwable cause) |
| Modifier and Type | Method and Description |
|---|---|
void |
SlimVaultClient.createToken(TokenRequest tokenRequest,
Handler<AsyncResult<Auth>> resultHandler)
Creates a new token.
|
void |
SlimVaultClient.delete(String path,
Handler<AsyncResult<Void>> resultHandler)
Deletes a secret from `path`.
|
void |
SlimVaultClient.list(String path,
Handler<AsyncResult<List<String>>> resultHandler)
Lists secrets from path (children).
|
void |
SlimVaultClient.loginWithAppRole(String roleId,
String secretId,
Handler<AsyncResult<Auth>> resultHandler)
Logs in against the `AppRole` backend.
|
void |
SlimVaultClient.loginWithCert(Handler<AsyncResult<Auth>> resultHandler)
Logs in against the `Cert` backend.
|
void |
SlimVaultClient.loginWithUserCredentials(String username,
String password,
Handler<AsyncResult<Auth>> resultHandler)
Logs in against the `userpass` backend.
|
void |
SlimVaultClient.lookupSelf(Handler<AsyncResult<Lookup>> resultHandler)
Looks up for the current token metadata.
|
void |
SlimVaultClient.read(String path,
Handler<AsyncResult<Secret>> responseHandler)
Reads a secret from `path`.
|
void |
SlimVaultClient.renewSelf(long leaseDurationInSecond,
Handler<AsyncResult<Auth>> resultHandler)
Renews the current token.
|
void |
SlimVaultClient.write(String path,
JsonObject secrets,
Handler<AsyncResult<Secret>> resultHandler)
Write a secret to `path`.
|
| Modifier and Type | Method and Description |
|---|---|
void |
YamlProcessor.process(Vertx vertx,
JsonObject configuration,
Buffer input,
Handler<AsyncResult<JsonObject>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
ZookeeperConfigStore.get(Handler<AsyncResult<Buffer>> completionHandler) |
| 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. |
interface |
Future<T>
Represents the result of an action that may, or may not, have occurred yet.
|
| Modifier and Type | Method and Description |
|---|---|
default <U> AsyncResult<U> |
AsyncResult.map(java.util.function.Function<T,U> mapper)
Apply a
mapper function on this async result. |
default <V> AsyncResult<V> |
AsyncResult.map(V value)
Map the result of this async result to a specific
value. |
default <V> AsyncResult<V> |
AsyncResult.mapEmpty()
Map the result of this async result to
null. |
default AsyncResult<T> |
AsyncResult.otherwise(java.util.function.Function<Throwable,T> mapper)
Apply a
mapper function on this async result. |
default AsyncResult<T> |
AsyncResult.otherwise(T value)
Map the failure of this async result to a specific
value. |
default AsyncResult<T> |
AsyncResult.otherwiseEmpty()
Map the failure of this async result to
null. |
| Modifier and Type | Method and Description |
|---|---|
default Handler<AsyncResult<T>> |
Future.completer()
Deprecated.
use this object instead since it extends
Handler<AsyncResult<T>> |
| Modifier and Type | Method and Description |
|---|---|
void |
Future.handle(AsyncResult<T> asyncResult)
Succeed or fail this future with the
AsyncResult event. |
void |
Promise.handle(AsyncResult<T> asyncResult)
Succeed or fail this promise with the
AsyncResult event. |
| Modifier and Type | Method and Description |
|---|---|
void |
Closeable.close(Handler<AsyncResult<Void>> completionHandler)
Close this resource, the
completionHandler must be notified when the operation has completed. |
void |
Vertx.close(Handler<AsyncResult<Void>> completionHandler)
Like
Vertx.close() but the completionHandler will be called when the close is complete |
static void |
Vertx.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler)
Creates a clustered instance using the specified options.
|
void |
Vertx.deployVerticle(Class<? extends Verticle> verticleClass,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(Verticle, DeploymentOptions, Handler) but Verticle instance is created by
invoking the default constructor of verticleClass. |
void |
Vertx.deployVerticle(String name,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(String, Handler) but DeploymentOptions are provided to configure the
deployment. |
void |
Vertx.deployVerticle(String name,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(String) but the completionHandler will be notified when the deployment is complete. |
void |
Vertx.deployVerticle(java.util.function.Supplier<Verticle> verticleSupplier,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(Verticle, DeploymentOptions, Handler) but Verticle instance is created by
invoking the verticleSupplier. |
void |
Vertx.deployVerticle(Verticle verticle,
DeploymentOptions options,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(Verticle, Handler) but DeploymentOptions are provided to configure the
deployment. |
void |
Vertx.deployVerticle(Verticle verticle,
Handler<AsyncResult<String>> completionHandler)
Like
Vertx.deployVerticle(Verticle) but the completionHandler will be notified when the deployment is complete. |
<T> void |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
boolean ordered,
Handler<AsyncResult<T>> resultHandler)
Safely execute some blocking code.
|
<T> void |
Context.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Invoke
Context.executeBlocking(Handler, boolean, Handler) with order = true. |
<T> void |
Vertx.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Like
Vertx.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
default <T> void |
WorkerExecutor.executeBlocking(Handler<Promise<T>> blockingCodeHandler,
Handler<AsyncResult<T>> resultHandler)
Like
WorkerExecutor.executeBlocking(Handler, boolean, Handler) called with ordered = true. |
CompositeFuture |
CompositeFuture.onComplete(Handler<AsyncResult<CompositeFuture>> handler) |
Future<T> |
Future.onComplete(Handler<AsyncResult<T>> handler)
Add a handler to be notified of the result.
|
default CompositeFuture |
CompositeFuture.setHandler(Handler<AsyncResult<CompositeFuture>> handler)
Deprecated.
|
default Future<T> |
Future.setHandler(Handler<AsyncResult<T>> handler)
Deprecated.
|
void |
Vertx.undeploy(String deploymentID,
Handler<AsyncResult<Void>> completionHandler)
Like
Vertx.undeploy(String) but the completionHandler will be notified when the undeployment is complete. |
| Modifier and Type | Method and Description |
|---|---|
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock,
Handler<AsyncResult<DatagramSocket>> handler)
Block the given address for the given multicast address and notifies the
Handler once
the operation completes. |
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String networkInterface,
String sourceToBlock,
Handler<AsyncResult<DatagramSocket>> handler)
Block the given address for the given multicast address on the given network interface and notifies
the
Handler once the operation completes. |
void |
DatagramSocket.close(Handler<AsyncResult<Void>> handler)
Closes the
DatagramSocket implementation asynchronous
and notifies the handler once done. |
DatagramSocket |
DatagramSocket.listen(int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Start listening on the given port and host.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
Handler<AsyncResult<DatagramSocket>> handler)
Joins a multicast group and listens for packets send to it.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<DatagramSocket>> handler)
Joins a multicast group and listens for packets send to it on the given network interface.
|
DatagramSocket |
DatagramSocket.send(Buffer packet,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
Buffer to the SocketAddress. |
DatagramSocket |
DatagramSocket.send(String str,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
String to the SocketAddress using UTF8 encoding. |
DatagramSocket |
DatagramSocket.send(String str,
String enc,
int port,
String host,
Handler<AsyncResult<DatagramSocket>> handler)
Write the given
String to the SocketAddress using the given encoding. |
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
Handler<AsyncResult<DatagramSocket>> handler)
Leaves a multicast group and stops listening for packets send to it.
|
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<DatagramSocket>> handler)
Leaves a multicast group and stops listening for packets send to it on the given network interface.
|
| Modifier and Type | Method and Description |
|---|---|
DnsClient |
DnsClient.lookup(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the A (ipv4) or AAAA (ipv6) record for the given name.
|
DnsClient |
DnsClient.lookup4(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the A (ipv4) record for the given name.
|
DnsClient |
DnsClient.lookup6(String name,
Handler<AsyncResult<String>> handler)
Try to lookup the AAAA (ipv6) record for the given name.
|
DnsClient |
DnsClient.resolveA(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve all A (ipv4) records for the given name.
|
DnsClient |
DnsClient.resolveAAAA(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve all AAAA (ipv6) records for the given name.
|
DnsClient |
DnsClient.resolveCNAME(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the CNAME record for the given name.
|
DnsClient |
DnsClient.resolveMX(String name,
Handler<AsyncResult<List<MxRecord>>> handler)
Try to resolve the MX records for the given name.
|
DnsClient |
DnsClient.resolveNS(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the NS records for the given name.
|
DnsClient |
DnsClient.resolvePTR(String name,
Handler<AsyncResult<String>> handler)
Try to resolve the PTR record for the given name.
|
DnsClient |
DnsClient.resolveSRV(String name,
Handler<AsyncResult<List<SrvRecord>>> handler)
Try to resolve the SRV records for the given name.
|
DnsClient |
DnsClient.resolveTXT(String name,
Handler<AsyncResult<List<String>>> handler)
Try to resolve the TXT records for the given name.
|
DnsClient |
DnsClient.reverseLookup(String ipaddress,
Handler<AsyncResult<String>> handler)
Try to do a reverse lookup of an IP address.
|
| Modifier and Type | Method and Description |
|---|---|
void |
EventBus.close(Handler<AsyncResult<Void>> completionHandler)
Close the event bus and release any resources held.
|
void |
MessageProducer.close(Handler<AsyncResult<Void>> handler)
Same as
MessageProducer.close() but with an handler called when the operation completes |
void |
MessageConsumer.completionHandler(Handler<AsyncResult<Void>> completionHandler)
Optional method which can be called to indicate when the registration has been propagated across the cluster.
|
void |
MessageProducer.end(Handler<AsyncResult<Void>> handler)
Closes the producer, calls
MessageProducer.close(Handler) |
<R> void |
Message.reply(Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<R>>> replyHandler)
Deprecated.
|
<R> void |
Message.reply(Object message,
Handler<AsyncResult<Message<R>>> replyHandler)
Deprecated.
|
default <R> void |
Message.replyAndRequest(Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<R>>> replyHandler)
Like
Message.replyAndRequest(Object, Handler) but specifying options that can be used
to configure the delivery. |
default <R> void |
Message.replyAndRequest(Object message,
Handler<AsyncResult<Message<R>>> replyHandler)
Reply to this message, specifying a
replyHandler for the reply - i.e. |
default <T> EventBus |
EventBus.request(String address,
Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<T>>> replyHandler)
Like
EventBus.request(String, Object, Handler) but specifying options that can be used to configure the delivery. |
default <T> EventBus |
EventBus.request(String address,
Object message,
Handler<AsyncResult<Message<T>>> replyHandler)
Sends a message and and specify a
replyHandler that will be called if the recipient
subsequently replies to the message. |
<T> EventBus |
EventBus.send(String address,
Object message,
DeliveryOptions options,
Handler<AsyncResult<Message<T>>> replyHandler)
Deprecated.
|
<T> EventBus |
EventBus.send(String address,
Object message,
Handler<AsyncResult<Message<T>>> replyHandler)
Deprecated.
use
EventBus.request(String, Object, Handler) instead |
<R> MessageProducer<T> |
MessageProducer.send(T message,
Handler<AsyncResult<Message<R>>> replyHandler)
Deprecated.
instead use
EventBus.request(String, Object, Handler) |
void |
EventBus.start(Handler<AsyncResult<Void>> completionHandler)
Start the event bus.
|
void |
MessageConsumer.unregister(Handler<AsyncResult<Void>> completionHandler)
Unregisters the handler which created this registration
|
MessageProducer<T> |
MessageProducer.write(T data,
Handler<AsyncResult<Void>> handler) |
| Modifier and Type | Method and Description |
|---|---|
FileSystem |
FileSystem.chmod(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Change the permissions on the file represented by
path to perms, asynchronously. |
FileSystem |
FileSystem.chmodRecursive(String path,
String perms,
String dirPerms,
Handler<AsyncResult<Void>> handler)
Change the permissions on the file represented by
path to perms, asynchronously. |
FileSystem |
FileSystem.chown(String path,
String user,
String group,
Handler<AsyncResult<Void>> handler)
Change the ownership on the file represented by
path to user and {code group}, asynchronously. |
void |
AsyncFile.close(Handler<AsyncResult<Void>> handler)
Close the file.
|
FileSystem |
FileSystem.copy(String from,
String to,
CopyOptions options,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to, asynchronously. |
FileSystem |
FileSystem.copy(String from,
String to,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to, asynchronously. |
FileSystem |
FileSystem.copyRecursive(String from,
String to,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Copy a file from the path
from to path to, asynchronously. |
FileSystem |
FileSystem.createFile(String path,
Handler<AsyncResult<Void>> handler)
Creates an empty file with the specified
path, asynchronously. |
FileSystem |
FileSystem.createFile(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Creates an empty file with the specified
path and permissions perms, asynchronously. |
FileSystem |
FileSystem.createTempDirectory(String prefix,
Handler<AsyncResult<String>> handler)
Creates a new directory in the default temporary-file directory, using the given
prefix to generate its name, asynchronously.
|
FileSystem |
FileSystem.createTempDirectory(String prefix,
String perms,
Handler<AsyncResult<String>> handler)
Creates a new directory in the default temporary-file directory, using the given
prefix to generate its name, asynchronously.
|
FileSystem |
FileSystem.createTempDirectory(String dir,
String prefix,
String perms,
Handler<AsyncResult<String>> handler)
Creates a new directory in the directory provided by the path
path, using the given
prefix to generate its name, asynchronously. |
FileSystem |
FileSystem.createTempFile(String prefix,
String suffix,
Handler<AsyncResult<String>> handler)
Creates a new file in the default temporary-file directory, using the given
prefix and suffix to generate its name, asynchronously.
|
FileSystem |
FileSystem.createTempFile(String prefix,
String suffix,
String perms,
Handler<AsyncResult<String>> handler)
Creates a new file in the directory provided by the path
dir, using the given
prefix and suffix to generate its name, asynchronously. |
FileSystem |
FileSystem.createTempFile(String dir,
String prefix,
String suffix,
String perms,
Handler<AsyncResult<String>> handler)
Creates a new file in the directory provided by the path
dir, using the given
prefix and suffix to generate its name, asynchronously. |
FileSystem |
FileSystem.delete(String path,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path, asynchronously. |
FileSystem |
FileSystem.deleteRecursive(String path,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path, asynchronously. |
void |
AsyncFile.end(Handler<AsyncResult<Void>> handler)
Close the file, see
AsyncFile.close(Handler). |
FileSystem |
FileSystem.exists(String path,
Handler<AsyncResult<Boolean>> handler)
Determines whether the file as specified by the path
path exists, asynchronously. |
AsyncFile |
AsyncFile.flush(Handler<AsyncResult<Void>> handler)
Same as
AsyncFile.flush() but the handler will be called when the flush is complete or if an error occurs |
FileSystem |
FileSystem.fsProps(String path,
Handler<AsyncResult<FileSystemProps>> handler)
Returns properties of the file-system being used by the specified
path, asynchronously. |
FileSystem |
FileSystem.link(String link,
String existing,
Handler<AsyncResult<Void>> handler)
Create a hard link on the file system from
link to existing, asynchronously. |
FileSystem |
FileSystem.lprops(String path,
Handler<AsyncResult<FileProps>> handler)
Obtain properties for the link represented by
path, asynchronously. |
FileSystem |
FileSystem.mkdir(String path,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path, asynchronously. |
FileSystem |
FileSystem.mkdir(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path, asynchronously. |
FileSystem |
FileSystem.mkdirs(String path,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path and any non existent parents, asynchronously. |
FileSystem |
FileSystem.mkdirs(String path,
String perms,
Handler<AsyncResult<Void>> handler)
Create the directory represented by
path and any non existent parents, asynchronously. |
FileSystem |
FileSystem.move(String from,
String to,
CopyOptions options,
Handler<AsyncResult<Void>> handler)
Move a file from the path
from to path to, asynchronously. |
FileSystem |
FileSystem.move(String from,
String to,
Handler<AsyncResult<Void>> handler)
Move a file from the path
from to path to, asynchronously. |
FileSystem |
FileSystem.open(String path,
OpenOptions options,
Handler<AsyncResult<AsyncFile>> handler)
Open the file represented by
path, asynchronously. |
FileSystem |
FileSystem.props(String path,
Handler<AsyncResult<FileProps>> handler)
Obtain properties for the file represented by
path, asynchronously. |
AsyncFile |
AsyncFile.read(Buffer buffer,
int offset,
long position,
int length,
Handler<AsyncResult<Buffer>> handler)
Reads
length bytes of data from the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.readDir(String path,
Handler<AsyncResult<List<String>>> handler)
Read the contents of the directory specified by
path, asynchronously. |
FileSystem |
FileSystem.readDir(String path,
String filter,
Handler<AsyncResult<List<String>>> handler)
Read the contents of the directory specified by
path, asynchronously. |
FileSystem |
FileSystem.readFile(String path,
Handler<AsyncResult<Buffer>> handler)
Reads the entire file as represented by the path
path as a Buffer, asynchronously. |
FileSystem |
FileSystem.readSymlink(String link,
Handler<AsyncResult<String>> handler)
Returns the path representing the file that the symbolic link specified by
link points to, asynchronously. |
FileSystem |
FileSystem.symlink(String link,
String existing,
Handler<AsyncResult<Void>> handler)
Create a symbolic link on the file system from
link to existing, asynchronously. |
FileSystem |
FileSystem.truncate(String path,
long len,
Handler<AsyncResult<Void>> handler)
Truncate the file represented by
path to length len in bytes, asynchronously. |
FileSystem |
FileSystem.unlink(String link,
Handler<AsyncResult<Void>> handler)
Unlinks the link on the file system represented by the path
link, asynchronously. |
AsyncFile |
AsyncFile.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
AsyncFile.write(Buffer) but with an handler called when the operation completes |
AsyncFile |
AsyncFile.write(Buffer buffer,
long position,
Handler<AsyncResult<Void>> handler)
Write a
Buffer to the file at position position in the file, asynchronously. |
FileSystem |
FileSystem.writeFile(String path,
Buffer data,
Handler<AsyncResult<Void>> handler)
Creates the file, and writes the specified
Buffer data to the file represented by the path path,
asynchronously. |
| Modifier and Type | Method and Description |
|---|---|
void |
HttpServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
HttpServer.close() but supplying a handler that will be called when the server is actually closed (or has failed). |
void |
WebSocketBase.close(Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.close() but with an handler called when the operation completes |
void |
WebSocketBase.close(short statusCode,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.close(short) but with an handler called when the operation completes |
void |
WebSocketBase.close(short statusCode,
String reason,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.close(short, String) but with an handler called when the operation completes |
void |
HttpServerResponse.end(Buffer chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.end(Buffer) but with an handler called when the operation completes |
void |
HttpClientRequest.end(Buffer chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.end(String) but with an handler called when the operation completes |
void |
HttpClientRequest.end(Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.end() but with an handler called when the operation completes |
void |
WebSocketBase.end(Handler<AsyncResult<Void>> handler)
|
void |
HttpServerResponse.end(String chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.end(String) but with an handler called when the operation completes |
void |
HttpClientRequest.end(String chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.end(String) but with an handler called when the operation completes |
void |
HttpServerResponse.end(String chunk,
String enc,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.end(String, String) but with an handler called when the operation completes |
void |
HttpClientRequest.end(String chunk,
String enc,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.end(String,String) but with an handler called when the operation completes |
HttpServer |
HttpServer.listen(Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen() but supplying a handler that will be called when the server is actually listening (or has failed). |
HttpServer |
HttpServer.listen(int port,
Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen(int) but supplying a handler that will be called when the server is actually listening (or has failed). |
HttpServer |
HttpServer.listen(int port,
String host,
Handler<AsyncResult<HttpServer>> listenHandler)
Like
HttpServer.listen(int, String) but supplying a handler that will be called when the server is actually
listening (or has failed). |
HttpServer |
HttpServer.listen(SocketAddress address,
Handler<AsyncResult<HttpServer>> listenHandler)
Tell the server to start listening on the given address supplying
a handler that will be called when the server is actually
listening (or has failed).
|
HttpConnection |
HttpConnection.ping(Buffer data,
Handler<AsyncResult<Buffer>> pongHandler)
Send a PING frame to the remote endpoint.
|
HttpServerResponse |
HttpServerResponse.push(HttpMethod method,
String path,
Handler<AsyncResult<HttpServerResponse>> handler)
Like
HttpServerResponse.push(HttpMethod, String, String, MultiMap, Handler) with the host copied from the current request. |
HttpServerResponse |
HttpServerResponse.push(HttpMethod method,
String path,
MultiMap headers,
Handler<AsyncResult<HttpServerResponse>> handler)
Like
HttpServerResponse.push(HttpMethod, String, String, MultiMap, Handler) with the host copied from the current request. |
HttpServerResponse |
HttpServerResponse.push(HttpMethod method,
String host,
String path,
Handler<AsyncResult<HttpServerResponse>> handler)
Like
HttpServerResponse.push(HttpMethod, String, String, MultiMap, Handler) with no headers. |
HttpServerResponse |
HttpServerResponse.push(HttpMethod method,
String host,
String path,
MultiMap headers,
Handler<AsyncResult<HttpServerResponse>> handler)
Push a response to the client.
The
handler will be notified with a success when the push can be sent and with
a failure when the client has disabled push or reset the push before it has been sent.
The handler may be queued if the client has reduced the maximum number of streams the server can push
concurrently.
Push can be sent only for peer initiated streams and if the response is not ended. |
default HttpServerResponse |
HttpServerResponse.sendFile(String filename,
Handler<AsyncResult<Void>> resultHandler)
Like
HttpServerResponse.sendFile(String) but providing a handler which will be notified once the file has been completely
written to the wire. |
default HttpServerResponse |
HttpServerResponse.sendFile(String filename,
long offset,
Handler<AsyncResult<Void>> resultHandler)
Like
HttpServerResponse.sendFile(String, long) but providing a handler which will be notified once the file has been completely
written to the wire. |
HttpServerResponse |
HttpServerResponse.sendFile(String filename,
long offset,
long length,
Handler<AsyncResult<Void>> resultHandler)
Like
HttpServerResponse.sendFile(String, long, long) but providing a handler which will be notified once the file has been
completely written to the wire. |
void |
ServerWebSocket.setHandshake(Future<Integer> future,
Handler<AsyncResult<Integer>> handler)
Set an asynchronous result for the handshake, upon completion of the specified
future, the
WebSocket will either be
accepted when the future succeeds with the HTTP 101 status code
rejected when the future is succeeds with an HTTP status code different than 101
rejected when the future fails with the HTTP status code 500
The provided future might be completed by the WebSocket itself, e.g calling the ServerWebSocket.close() method
will try to accept the handshake and close the WebSocket afterward. |
default void |
HttpServerRequest.toNetSocket(Handler<AsyncResult<NetSocket>> handler)
Establish a TCP tunnel with the client.
|
default void |
HttpServerRequest.toWebSocket(Handler<AsyncResult<ServerWebSocket>> handler)
Upgrade the connection of the current request to a WebSocket.
|
HttpConnection |
HttpConnection.updateSettings(Http2Settings settings,
Handler<AsyncResult<Void>> completionHandler)
Send to the remote endpoint an update of this endpoint settings
The
completionHandler will be notified when the remote endpoint has acknowledged the settings. |
void |
HttpClient.webSocket(int port,
String host,
String requestURI,
Handler<AsyncResult<WebSocket>> handler)
Connect a WebSocket to the specified port, host and relative request URI
|
void |
HttpClient.webSocket(String requestURI,
Handler<AsyncResult<WebSocket>> handler)
Connect a WebSocket at the relative request URI using the default host and port
|
void |
HttpClient.webSocket(String host,
String requestURI,
Handler<AsyncResult<WebSocket>> handler)
Connect a WebSocket to the host and relative request URI and default port
|
void |
HttpClient.webSocket(WebSocketConnectOptions options,
Handler<AsyncResult<WebSocket>> handler)
Connect a WebSocket with the specified options.
|
void |
HttpClient.webSocketAbs(String url,
MultiMap headers,
WebsocketVersion version,
List<String> subProtocols,
Handler<AsyncResult<WebSocket>> handler)
Connect a WebSocket with the specified absolute url, with the specified headers, using
the specified version of WebSockets, and the specified WebSocket sub protocols.
|
HttpServerResponse |
HttpServerResponse.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.write(Buffer) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
HttpClientRequest |
HttpClientRequest.write(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.write(Buffer) but with an handler called when the operation completes |
WebSocket |
WebSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
HttpServerResponse |
HttpServerResponse.write(String chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.write(String) but with an handler called when the operation completes |
HttpClientRequest |
HttpClientRequest.write(String chunk,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.write(String) but with an handler called when the operation completes |
HttpServerResponse |
HttpServerResponse.write(String chunk,
String enc,
Handler<AsyncResult<Void>> handler)
Same as
HttpServerResponse.write(String, String) but with an handler called when the operation completes |
HttpClientRequest |
HttpClientRequest.write(String chunk,
String enc,
Handler<AsyncResult<Void>> handler)
Same as
HttpClientRequest.write(String,String) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeBinaryMessage(Buffer) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFinalBinaryFrame(Buffer, Handler) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.writeFinalTextFrame(String text,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeFinalTextFrame(String text,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeFinalTextFrame(String text,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFinalTextFrame(String, Handler) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.writeFrame(WebSocketFrame frame,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeFrame(WebSocketFrame frame,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeFrame(WebSocketFrame frame,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFrame(WebSocketFrame) but with an handler called when the operation completes |
ServerWebSocket |
ServerWebSocket.writeTextMessage(String text,
Handler<AsyncResult<Void>> handler) |
WebSocket |
WebSocket.writeTextMessage(String text,
Handler<AsyncResult<Void>> handler) |
WebSocketBase |
WebSocketBase.writeTextMessage(String text,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeTextMessage(String) but with an handler called when the operation completes |
| Modifier and Type | Method and Description |
|---|---|
void |
NetSocket.close(Handler<AsyncResult<Void>> handler)
Close the NetSocket and notify the
handler when the operation completes. |
void |
NetServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
NetServer.close() but supplying a handler that will be notified when close is complete. |
NetClient |
NetClient.connect(int port,
String host,
Handler<AsyncResult<NetSocket>> connectHandler)
Open a connection to a server at the specific
port and host. |
NetClient |
NetClient.connect(int port,
String host,
String serverName,
Handler<AsyncResult<NetSocket>> connectHandler)
Open a connection to a server at the specific
port and host. |
NetClient |
NetClient.connect(SocketAddress remoteAddress,
Handler<AsyncResult<NetSocket>> connectHandler)
Open a connection to a server at the specific
remoteAddress. |
NetClient |
NetClient.connect(SocketAddress remoteAddress,
String serverName,
Handler<AsyncResult<NetSocket>> connectHandler)
Open a connection to a server at the specific
remoteAddress. |
void |
NetSocket.end(Handler<AsyncResult<Void>> handler)
Calls
NetSocket.end(Handler) |
NetServer |
NetServer.listen(Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen() but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(int port,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen(int) but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(int port,
String host,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen(int, String) but providing a handler that will be notified when the server is listening, or fails. |
NetServer |
NetServer.listen(SocketAddress localAddress,
Handler<AsyncResult<NetServer>> listenHandler)
Like
NetServer.listen(SocketAddress) but providing a handler that will be notified when the server is listening, or fails. |
default NetSocket |
NetSocket.sendFile(String filename,
Handler<AsyncResult<Void>> resultHandler)
Same as
NetSocket.sendFile(String) but also takes a handler that will be called when the send has completed or
a failure has occurred |
default NetSocket |
NetSocket.sendFile(String filename,
long offset,
Handler<AsyncResult<Void>> resultHandler)
Same as
NetSocket.sendFile(String, long) but also takes a handler that will be called when the send has completed or
a failure has occurred |
NetSocket |
NetSocket.sendFile(String filename,
long offset,
long length,
Handler<AsyncResult<Void>> resultHandler)
Same as
NetSocket.sendFile(String, long, long) but also takes a handler that will be called when the send has completed or
a failure has occurred |
NetSocket |
NetSocket.write(Buffer message,
Handler<AsyncResult<Void>> handler)
Like
WriteStream.write(Object) but with an handler called when the message has been written
or failed to be written. |
NetSocket |
NetSocket.write(String str,
Handler<AsyncResult<Void>> handler)
Same as
NetSocket.write(String) but with an handler called when the operation completes |
NetSocket |
NetSocket.write(String str,
String enc,
Handler<AsyncResult<Void>> handler)
Same as
NetSocket.write(String, String) but with an handler called when the operation completes |
| Modifier and Type | Method and Description |
|---|---|
void |
Counter.addAndGet(long value,
Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the new count
|
void |
AsyncMap.clear(Handler<AsyncResult<Void>> resultHandler)
Clear all entries in the map
|
void |
Counter.compareAndSet(long expected,
long value,
Handler<AsyncResult<Boolean>> resultHandler)
Set the counter to the specified value only if the current value is the expectec value.
|
void |
Counter.decrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Decrement the counter atomically and return the new count
|
void |
AsyncMap.entries(Handler<AsyncResult<Map<K,V>>> resultHandler)
Get the entries of the map, asynchronously.
|
void |
Counter.get(Handler<AsyncResult<Long>> resultHandler)
Get the current value of the counter
|
void |
AsyncMap.get(K k,
Handler<AsyncResult<V>> resultHandler)
Get a value from the map, asynchronously.
|
void |
Counter.getAndAdd(long value,
Handler<AsyncResult<Long>> resultHandler)
Add the value to the counter atomically and return the value before the add
|
void |
Counter.getAndIncrement(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the value before the increment.
|
<K,V> void |
SharedData.getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Get the
AsyncMap with the specified name. |
<K,V> void |
SharedData.getClusterWideMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Get the cluster wide map with the specified name.
|
void |
SharedData.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler)
Get an asynchronous counter.
|
<K,V> void |
SharedData.getLocalAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Get the
AsyncMap with the specified name. |
void |
SharedData.getLocalCounter(String name,
Handler<AsyncResult<Counter>> resultHandler)
Get an asynchronous local counter.
|
void |
SharedData.getLocalLock(String name,
Handler<AsyncResult<Lock>> resultHandler)
Get an asynchronous local lock with the specified name.
|
void |
SharedData.getLocalLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler)
Like
SharedData.getLocalLock(String, Handler) but specifying a timeout. |
void |
SharedData.getLock(String name,
Handler<AsyncResult<Lock>> resultHandler)
Get an asynchronous lock with the specified name.
|
void |
SharedData.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler)
Like
SharedData.getLock(String, Handler) but specifying a timeout. |
void |
Counter.incrementAndGet(Handler<AsyncResult<Long>> resultHandler)
Increment the counter atomically and return the new count
|
void |
AsyncMap.keys(Handler<AsyncResult<Set<K>>> resultHandler)
Get the keys of the map, asynchronously.
|
void |
AsyncMap.put(K k,
V v,
Handler<AsyncResult<Void>> completionHandler)
Put a value in the map, asynchronously.
|
void |
AsyncMap.put(K k,
V v,
long ttl,
Handler<AsyncResult<Void>> completionHandler)
Like
AsyncMap.put(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.lang.Void>>) but specifying a time to live for the entry. |
void |
AsyncMap.putIfAbsent(K k,
V v,
Handler<AsyncResult<V>> completionHandler)
Put the entry only if there is no entry with the key already present.
|
void |
AsyncMap.putIfAbsent(K k,
V v,
long ttl,
Handler<AsyncResult<V>> completionHandler)
Link
AsyncMap.putIfAbsent(K, V, io.vertx.core.Handler<io.vertx.core.AsyncResult<V>>) but specifying a time to live for the entry. |
void |
AsyncMap.remove(K k,
Handler<AsyncResult<V>> resultHandler)
Remove a value from the map, asynchronously.
|
void |
AsyncMap.removeIfPresent(K k,
V v,
Handler<AsyncResult<Boolean>> resultHandler)
Remove a value from the map, only if entry already exists with same value.
|
void |
AsyncMap.replace(K k,
V v,
Handler<AsyncResult<V>> resultHandler)
Replace the entry only if it is currently mapped to some value
|
void |
AsyncMap.replaceIfPresent(K k,
V oldValue,
V newValue,
Handler<AsyncResult<Boolean>> resultHandler)
Replace the entry only if it is currently mapped to a specific value
|
void |
AsyncMap.size(Handler<AsyncResult<Integer>> resultHandler)
Provide the number of entries in the map
|
void |
AsyncMap.values(Handler<AsyncResult<List<V>>> resultHandler)
Get the values of the map, asynchronously.
|
| Modifier and Type | Method and Description |
|---|---|
void |
VertxFactory.clusteredVertx(VertxOptions options,
Handler<AsyncResult<Vertx>> resultHandler) |
void |
VertxFactory.clusteredVertx(VertxOptions options,
io.vertx.core.net.impl.transport.Transport transport,
Handler<AsyncResult<Vertx>> resultHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
AsyncMultiMap.add(K k,
V v,
Handler<AsyncResult<Void>> completionHandler)
Add a value to the values for that key in the map.
|
void |
AsyncMultiMap.get(K k,
Handler<AsyncResult<ChoosableIterable<V>>> resultHandler)
Get the values from the map for the key.
|
<K,V> void |
ClusterManager.getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler)
Return an async map for the given name
|
<K,V> void |
ClusterManager.getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler)
Return an async multi-map for the given name
|
void |
ClusterManager.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
void |
ClusterManager.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler) |
void |
ClusterManager.join(Handler<AsyncResult<Void>> resultHandler)
Join the cluster
|
void |
ClusterManager.leave(Handler<AsyncResult<Void>> resultHandler)
Leave the cluster
|
void |
AsyncMultiMap.remove(K k,
V v,
Handler<AsyncResult<Boolean>> completionHandler)
Remove a value from the values of that key in the map.
|
void |
AsyncMultiMap.removeAllForValue(V v,
Handler<AsyncResult<Void>> completionHandler)
Remove the specified value from all values found
equals associated to all keys in the map. |
void |
AsyncMultiMap.removeAllMatching(java.util.function.Predicate<V> p,
Handler<AsyncResult<Void>> completionHandler)
Remove values which satisfies the given predicate in all keys.
|
| Modifier and Type | Method and Description |
|---|---|
void |
WriteStream.end(Handler<AsyncResult<Void>> handler)
Same as
WriteStream.end() but with an handler called when the operation completes |
default void |
WriteStream.end(T data,
Handler<AsyncResult<Void>> handler)
Same as
#end(T) but with an handler called when the operation completes |
default void |
ReadStream.pipeTo(WriteStream<T> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
void |
Pipe.to(WriteStream<T> dst,
Handler<AsyncResult<Void>> completionHandler)
Start to pipe the elements to the destination
WriteStream. |
WriteStream<T> |
WriteStream.write(T data,
Handler<AsyncResult<Void>> handler)
Same as
#write(T) but with an handler called when the operation completes |
| Modifier and Type | Method and Description |
|---|---|
static void |
DB2Connection.connect(Vertx vertx,
DB2ConnectOptions connectOptions,
Handler<AsyncResult<DB2Connection>> handler)
Create a connection to DB2 server with the given
connectOptions. |
static void |
DB2Connection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<DB2Connection>> handler)
Like
DB2Connection.connect(Vertx, DB2ConnectOptions, Handler) with options build
from connectionUri. |
DB2Connection |
DB2Connection.debug(Handler<AsyncResult<Void>> handler)
Send a DEBUG command to dump debug information to the server's stdout.
|
DB2Connection |
DB2Connection.ping(Handler<AsyncResult<Void>> handler)
Send a PING command to check if the server is alive.
|
DB2Connection |
DB2Connection.prepare(String sql,
Handler<AsyncResult<PreparedStatement>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
AuthProvider.authenticate(JsonObject authInfo,
Handler<AsyncResult<User>> resultHandler)
Authenticate a user.
|
protected abstract void |
AbstractUser.doIsPermitted(String permission,
Handler<AsyncResult<Boolean>> resultHandler)
Deprecated.
|
default User |
User.isAuthorised(String authority,
Handler<AsyncResult<Boolean>> resultHandler)
Deprecated.
|
User |
AbstractUser.isAuthorized(String authority,
Handler<AsyncResult<Boolean>> resultHandler)
Deprecated.
|
User |
User.isAuthorized(String authority,
Handler<AsyncResult<Boolean>> resultHandler)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MongoAuth.insertUser(String username,
String password,
List<String> roles,
List<String> permissions,
Handler<AsyncResult<String>> resultHandler)
Insert a new user into mongo in the convenient way
|
| Modifier and Type | Method and Description |
|---|---|
OAuth2Auth |
OAuth2Auth.decodeToken(String token,
Handler<AsyncResult<AccessToken>> handler)
Deprecated.
use
AuthProvider.authenticate(JsonObject, Handler) instead. |
AccessToken |
AccessToken.fetch(HttpMethod method,
String resource,
JsonObject headers,
Buffer payload,
Handler<AsyncResult<OAuth2Response>> callback)
Deprecated.
Fetches a JSON resource using this Access Token.
|
default AccessToken |
AccessToken.fetch(String resource,
Handler<AsyncResult<OAuth2Response>> callback)
Deprecated.
Fetches a JSON resource using this Access Token.
|
void |
OAuth2Auth.getToken(JsonObject params,
Handler<AsyncResult<AccessToken>> handler)
Deprecated.
use
AuthProvider.authenticate(JsonObject, Handler) instead. |
AccessToken |
AccessToken.introspect(Handler<AsyncResult<Void>> callback)
Deprecated.
Introspect access token.
|
AccessToken |
AccessToken.introspect(String tokenType,
Handler<AsyncResult<Void>> callback)
Deprecated.
Introspect access token.
|
default OAuth2Auth |
OAuth2Auth.introspectToken(String token,
Handler<AsyncResult<AccessToken>> handler)
Deprecated.
|
OAuth2Auth |
OAuth2Auth.introspectToken(String token,
String tokenType,
Handler<AsyncResult<AccessToken>> handler)
Deprecated.
|
void |
OAuth2RBAC.isAuthorized(AccessToken user,
String authority,
Handler<AsyncResult<Boolean>> handler)
This method should verify if the user has the given authority and return either a boolean value or an error.
|
OAuth2Auth |
OAuth2Auth.loadJWK(Handler<AsyncResult<Void>> handler)
Deprecated.
|
AccessToken |
AccessToken.logout(Handler<AsyncResult<Void>> callback)
Deprecated.
Revoke refresh token and calls the logout endpoint.
|
AccessToken |
AccessToken.refresh(Handler<AsyncResult<Void>> callback)
Deprecated.
Refresh the access token
|
AccessToken |
AccessToken.revoke(String token_type,
Handler<AsyncResult<Void>> callback)
Deprecated.
Revoke access or refresh token
|
AccessToken |
AccessToken.userInfo(Handler<AsyncResult<JsonObject>> callback)
Deprecated.
Load the user info as per OIDC spec.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
SalesforceAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
GoogleAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
AzureADAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
OpenIDConnectAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
static void |
KeycloakAuth.discover(Vertx vertx,
OAuth2ClientOptions config,
Handler<AsyncResult<OAuth2Auth>> handler)
Create a OAuth2Auth provider for OpenID Connect Discovery.
|
| Modifier and Type | Method and Description |
|---|---|
<K,V> void |
InfinispanClusterManager.getAsyncMap(String name,
Handler<AsyncResult<AsyncMap<K,V>>> resultHandler) |
<K,V> void |
InfinispanClusterManager.getAsyncMultiMap(String name,
Handler<AsyncResult<AsyncMultiMap<K,V>>> resultHandler) |
void |
InfinispanClusterManager.getCounter(String name,
Handler<AsyncResult<Counter>> resultHandler) |
void |
InfinispanClusterManager.getLockWithTimeout(String name,
long timeout,
Handler<AsyncResult<Lock>> resultHandler) |
void |
InfinispanClusterManager.join(Handler<AsyncResult<Void>> resultHandler) |
void |
InfinispanClusterManager.leave(Handler<AsyncResult<Void>> resultHandler) |
| Modifier and Type | Method and Description |
|---|---|
ConsulClient |
ConsulClient.agentInfo(Handler<AsyncResult<JsonObject>> resultHandler)
Returns the configuration and member information of the local agent
|
ConsulService |
ConsulService.agentInfo(Handler<AsyncResult<JsonObject>> resultHandler) |
ConsulClient |
ConsulClient.catalogDatacenters(Handler<AsyncResult<List<String>>> resultHandler)
Return all the datacenters that are known by the Consul server
|
ConsulService |
ConsulService.catalogDatacenters(Handler<AsyncResult<List<String>>> resultHandler) |
ConsulClient |
ConsulClient.catalogNodes(Handler<AsyncResult<NodeList>> resultHandler)
Returns the nodes registered in a datacenter
|
ConsulService |
ConsulService.catalogNodes(Handler<AsyncResult<NodeList>> resultHandler) |
ConsulClient |
ConsulClient.catalogNodeServices(String node,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the node's registered services
|
ConsulService |
ConsulService.catalogNodeServices(String node,
Handler<AsyncResult<ServiceList>> resultHandler) |
ConsulClient |
ConsulClient.catalogNodeServicesWithOptions(String node,
BlockingQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the node's registered services
This is blocking query unlike
ConsulClient.catalogNodeServices(String, Handler) |
ConsulService |
ConsulService.catalogNodeServicesWithOptions(String node,
BlockingQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler) |
ConsulClient |
ConsulClient.catalogNodesWithOptions(NodeQueryOptions options,
Handler<AsyncResult<NodeList>> resultHandler)
Returns the nodes registered in a datacenter
|
ConsulService |
ConsulService.catalogNodesWithOptions(NodeQueryOptions options,
Handler<AsyncResult<NodeList>> resultHandler) |
ConsulClient |
ConsulClient.catalogServiceNodes(String service,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the nodes providing a service
|
ConsulService |
ConsulService.catalogServiceNodes(String service,
Handler<AsyncResult<ServiceList>> resultHandler) |
ConsulClient |
ConsulClient.catalogServiceNodesWithOptions(String service,
ServiceQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the nodes providing a service
|
ConsulService |
ConsulService.catalogServiceNodesWithOptions(String service,
ServiceQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler) |
ConsulClient |
ConsulClient.catalogServices(Handler<AsyncResult<ServiceList>> resultHandler)
Returns the services registered in a datacenter
|
ConsulService |
ConsulService.catalogServices(Handler<AsyncResult<ServiceList>> resultHandler) |
ConsulClient |
ConsulClient.catalogServicesWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler)
Returns the services registered in a datacenter
This is blocking query unlike
ConsulClient.catalogServices(Handler) |
ConsulService |
ConsulService.catalogServicesWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<ServiceList>> resultHandler) |
ConsulClient |
ConsulClient.cloneAclToken(String id,
Handler<AsyncResult<String>> idHandler)
Clone Acl token
|
ConsulService |
ConsulService.cloneAclToken(String id,
Handler<AsyncResult<String>> idHandler) |
ConsulClient |
ConsulClient.coordinateDatacenters(Handler<AsyncResult<List<DcCoordinates>>> resultHandler)
Returns the WAN network coordinates for all Consul servers, organized by DCs
|
ConsulService |
ConsulService.coordinateDatacenters(Handler<AsyncResult<List<DcCoordinates>>> resultHandler) |
ConsulClient |
ConsulClient.coordinateNodes(Handler<AsyncResult<CoordinateList>> resultHandler)
Returns the LAN network coordinates for all nodes in a given DC
|
ConsulService |
ConsulService.coordinateNodes(Handler<AsyncResult<CoordinateList>> resultHandler) |
ConsulClient |
ConsulClient.coordinateNodesWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<CoordinateList>> resultHandler)
Returns the LAN network coordinates for all nodes in a given DC
This is blocking query unlike
ConsulClient.coordinateNodes(Handler) |
ConsulService |
ConsulService.coordinateNodesWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<CoordinateList>> resultHandler) |
ConsulClient |
ConsulClient.createAclToken(AclToken token,
Handler<AsyncResult<String>> idHandler)
Create new Acl token
|
ConsulService |
ConsulService.createAclToken(AclToken token,
Handler<AsyncResult<String>> idHandler) |
ConsulClient |
ConsulClient.createPreparedQuery(PreparedQueryDefinition definition,
Handler<AsyncResult<String>> resultHandler) |
ConsulService |
ConsulService.createPreparedQuery(PreparedQueryDefinition definition,
Handler<AsyncResult<String>> resultHandler) |
ConsulClient |
ConsulClient.createSession(Handler<AsyncResult<String>> idHandler)
Initialize a new session
|
ConsulService |
ConsulService.createSession(Handler<AsyncResult<String>> idHandler) |
ConsulClient |
ConsulClient.createSessionWithOptions(SessionOptions options,
Handler<AsyncResult<String>> idHandler)
Initialize a new session
|
ConsulService |
ConsulService.createSessionWithOptions(SessionOptions options,
Handler<AsyncResult<String>> idHandler) |
ConsulClient |
ConsulClient.deletePreparedQuery(String id,
Handler<AsyncResult<Void>> resultHandler)
Deletes an existing prepared query
|
ConsulService |
ConsulService.deletePreparedQuery(String id,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.deleteValue(String key,
Handler<AsyncResult<Void>> resultHandler)
Remove the key/value pair that corresponding to the specified key
|
ConsulService |
ConsulService.deleteValue(String key,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.deleteValues(String keyPrefix,
Handler<AsyncResult<Void>> resultHandler)
Removes all the key/value pair that corresponding to the specified key prefix
|
ConsulService |
ConsulService.deleteValues(String keyPrefix,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.deregisterCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Remove a check from the local agent.
|
ConsulService |
ConsulService.deregisterCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.deregisterService(String id,
Handler<AsyncResult<Void>> resultHandler)
Remove a service from the local agent.
|
ConsulService |
ConsulService.deregisterService(String id,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.destroyAclToken(String id,
Handler<AsyncResult<Void>> resultHandler)
Destroy Acl token
|
ConsulService |
ConsulService.destroyAclToken(String id,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.destroySession(String id,
Handler<AsyncResult<Void>> resultHandler)
Destroys the given session
|
ConsulService |
ConsulService.destroySession(String id,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.executePreparedQuery(String query,
Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler)
Executes an existing prepared query.
|
ConsulService |
ConsulService.executePreparedQuery(String query,
Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler) |
ConsulClient |
ConsulClient.executePreparedQueryWithOptions(String query,
PreparedQueryExecuteOptions options,
Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler)
Executes an existing prepared query.
|
ConsulService |
ConsulService.executePreparedQueryWithOptions(String query,
PreparedQueryExecuteOptions options,
Handler<AsyncResult<PreparedQueryExecuteResponse>> resultHandler) |
ConsulClient |
ConsulClient.failCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "critical".
|
ConsulService |
ConsulService.failCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.failCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "critical".
|
ConsulService |
ConsulService.failCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.fireEvent(String name,
Handler<AsyncResult<Event>> resultHandler)
Fires a new user event
|
ConsulService |
ConsulService.fireEvent(String name,
Handler<AsyncResult<Event>> resultHandler) |
ConsulClient |
ConsulClient.fireEventWithOptions(String name,
EventOptions options,
Handler<AsyncResult<Event>> resultHandler)
Fires a new user event
|
ConsulService |
ConsulService.fireEventWithOptions(String name,
EventOptions options,
Handler<AsyncResult<Event>> resultHandler) |
ConsulClient |
ConsulClient.getAllPreparedQueries(Handler<AsyncResult<List<PreparedQueryDefinition>>> resultHandler)
Returns a list of all prepared queries.
|
ConsulService |
ConsulService.getAllPreparedQueries(Handler<AsyncResult<List<PreparedQueryDefinition>>> resultHandler) |
ConsulClient |
ConsulClient.getKeys(String keyPrefix,
Handler<AsyncResult<List<String>>> resultHandler)
Returns the list of keys that corresponding to the specified key prefix.
|
ConsulService |
ConsulService.getKeys(String keyPrefix,
Handler<AsyncResult<List<String>>> resultHandler) |
ConsulClient |
ConsulClient.getKeysWithOptions(String keyPrefix,
BlockingQueryOptions options,
Handler<AsyncResult<List<String>>> resultHandler)
Returns the list of keys that corresponding to the specified key prefix.
|
ConsulService |
ConsulService.getKeysWithOptions(String keyPrefix,
BlockingQueryOptions options,
Handler<AsyncResult<List<String>>> resultHandler) |
ConsulClient |
ConsulClient.getPreparedQuery(String id,
Handler<AsyncResult<PreparedQueryDefinition>> resultHandler)
Returns an existing prepared query
|
ConsulService |
ConsulService.getPreparedQuery(String id,
Handler<AsyncResult<PreparedQueryDefinition>> resultHandler) |
ConsulClient |
ConsulClient.getValue(String key,
Handler<AsyncResult<KeyValue>> resultHandler)
Returns key/value pair that corresponding to the specified key.
|
ConsulService |
ConsulService.getValue(String key,
Handler<AsyncResult<KeyValue>> resultHandler) |
ConsulClient |
ConsulClient.getValues(String keyPrefix,
Handler<AsyncResult<KeyValueList>> resultHandler)
Returns the list of key/value pairs that corresponding to the specified key prefix.
|
ConsulService |
ConsulService.getValues(String keyPrefix,
Handler<AsyncResult<KeyValueList>> resultHandler) |
ConsulClient |
ConsulClient.getValuesWithOptions(String keyPrefix,
BlockingQueryOptions options,
Handler<AsyncResult<KeyValueList>> resultHandler)
Returns the list of key/value pairs that corresponding to the specified key prefix.
|
ConsulService |
ConsulService.getValuesWithOptions(String keyPrefix,
BlockingQueryOptions options,
Handler<AsyncResult<KeyValueList>> resultHandler) |
ConsulClient |
ConsulClient.getValueWithOptions(String key,
BlockingQueryOptions options,
Handler<AsyncResult<KeyValue>> resultHandler)
Returns key/value pair that corresponding to the specified key.
|
ConsulService |
ConsulService.getValueWithOptions(String key,
BlockingQueryOptions options,
Handler<AsyncResult<KeyValue>> resultHandler) |
ConsulClient |
ConsulClient.healthChecks(String service,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks associated with the service
|
ConsulService |
ConsulService.healthChecks(String service,
Handler<AsyncResult<CheckList>> resultHandler) |
ConsulClient |
ConsulClient.healthChecksWithOptions(String service,
CheckQueryOptions options,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks associated with the service
|
ConsulService |
ConsulService.healthChecksWithOptions(String service,
CheckQueryOptions options,
Handler<AsyncResult<CheckList>> resultHandler) |
ConsulClient |
ConsulClient.healthServiceNodes(String service,
boolean passing,
Handler<AsyncResult<ServiceEntryList>> resultHandler)
Returns the nodes providing the service.
|
ConsulService |
ConsulService.healthServiceNodes(String service,
boolean passing,
Handler<AsyncResult<ServiceEntryList>> resultHandler) |
ConsulClient |
ConsulClient.healthServiceNodesWithOptions(String service,
boolean passing,
ServiceQueryOptions options,
Handler<AsyncResult<ServiceEntryList>> resultHandler)
Returns the nodes providing the service.
|
ConsulService |
ConsulService.healthServiceNodesWithOptions(String service,
boolean passing,
ServiceQueryOptions options,
Handler<AsyncResult<ServiceEntryList>> resultHandler) |
ConsulClient |
ConsulClient.healthState(HealthState healthState,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks in the specified status
|
ConsulService |
ConsulService.healthState(HealthState healthState,
Handler<AsyncResult<CheckList>> handler) |
ConsulClient |
ConsulClient.healthStateWithOptions(HealthState healthState,
CheckQueryOptions options,
Handler<AsyncResult<CheckList>> resultHandler)
Returns the checks in the specified status
|
ConsulService |
ConsulService.healthStateWithOptions(HealthState healthState,
CheckQueryOptions checkQueryOptions,
Handler<AsyncResult<CheckList>> handler) |
ConsulClient |
ConsulClient.infoAclToken(String id,
Handler<AsyncResult<AclToken>> tokenHandler)
Get info of Acl token
|
ConsulService |
ConsulService.infoAclToken(String id,
Handler<AsyncResult<AclToken>> tokenHandler) |
ConsulClient |
ConsulClient.infoSession(String id,
Handler<AsyncResult<Session>> resultHandler)
Returns the requested session information
|
ConsulService |
ConsulService.infoSession(String id,
Handler<AsyncResult<Session>> resultHandler) |
ConsulClient |
ConsulClient.infoSessionWithOptions(String id,
BlockingQueryOptions options,
Handler<AsyncResult<Session>> resultHandler)
Returns the requested session information
This is blocking query unlike
ConsulClient.infoSession(String, Handler) |
ConsulService |
ConsulService.infoSessionWithOptions(String id,
BlockingQueryOptions options,
Handler<AsyncResult<Session>> resultHandler) |
ConsulClient |
ConsulClient.leaderStatus(Handler<AsyncResult<String>> resultHandler)
Get the Raft leader for the datacenter in which the agent is running.
|
ConsulService |
ConsulService.leaderStatus(Handler<AsyncResult<String>> resultHandler) |
ConsulClient |
ConsulClient.listAclTokens(Handler<AsyncResult<List<AclToken>>> resultHandler)
Get list of Acl token
|
ConsulService |
ConsulService.listAclTokens(Handler<AsyncResult<List<AclToken>>> resultHandler) |
ConsulClient |
ConsulClient.listEvents(Handler<AsyncResult<EventList>> resultHandler)
Returns the most recent events known by the agent
|
ConsulService |
ConsulService.listEvents(Handler<AsyncResult<EventList>> resultHandler) |
ConsulClient |
ConsulClient.listEventsWithOptions(EventListOptions options,
Handler<AsyncResult<EventList>> resultHandler)
Returns the most recent events known by the agent.
|
ConsulService |
ConsulService.listEventsWithOptions(EventListOptions options,
Handler<AsyncResult<EventList>> resultHandler) |
ConsulClient |
ConsulClient.listNodeSessions(String nodeId,
Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions for a given node
|
ConsulService |
ConsulService.listNodeSessions(String nodeId,
Handler<AsyncResult<SessionList>> resultHandler) |
ConsulClient |
ConsulClient.listNodeSessionsWithOptions(String nodeId,
BlockingQueryOptions options,
Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions for a given node
This is blocking query unlike
ConsulClient.listNodeSessions(String, Handler) |
ConsulService |
ConsulService.listNodeSessionsWithOptions(String nodeId,
BlockingQueryOptions options,
Handler<AsyncResult<SessionList>> resultHandler) |
ConsulClient |
ConsulClient.listSessions(Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions
|
ConsulService |
ConsulService.listSessions(Handler<AsyncResult<SessionList>> resultHandler) |
ConsulClient |
ConsulClient.listSessionsWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<SessionList>> resultHandler)
Returns the active sessions
This is blocking query unlike
ConsulClient.listSessions(Handler) |
ConsulService |
ConsulService.listSessionsWithOptions(BlockingQueryOptions options,
Handler<AsyncResult<SessionList>> resultHandler) |
ConsulClient |
ConsulClient.localChecks(Handler<AsyncResult<List<Check>>> resultHandler)
Return all the checks that are registered with the local agent.
|
ConsulService |
ConsulService.localChecks(Handler<AsyncResult<List<Check>>> resultHandler) |
ConsulClient |
ConsulClient.localServices(Handler<AsyncResult<List<Service>>> resultHandler)
Returns list of services registered with the local agent.
|
ConsulService |
ConsulService.localServices(Handler<AsyncResult<List<Service>>> resultHandler) |
ConsulClient |
ConsulClient.maintenanceService(MaintenanceOptions maintenanceOptions,
Handler<AsyncResult<Void>> resultHandler)
Places a given service into "maintenance mode"
|
ConsulService |
ConsulService.maintenanceService(MaintenanceOptions maintenanceOptions,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.passCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "passing".
|
ConsulService |
ConsulService.passCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.passCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "passing".
|
ConsulService |
ConsulService.passCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.peersStatus(Handler<AsyncResult<List<String>>> resultHandler)
Retrieves the Raft peers for the datacenter in which the the agent is running.
|
ConsulService |
ConsulService.peersStatus(Handler<AsyncResult<List<String>>> resultHandler) |
ConsulClient |
ConsulClient.putValue(String key,
String value,
Handler<AsyncResult<Boolean>> resultHandler)
Adds specified key/value pair
|
ConsulService |
ConsulService.putValue(String key,
String value,
Handler<AsyncResult<Boolean>> resultHandler) |
ConsulClient |
ConsulClient.putValueWithOptions(String key,
String value,
KeyValueOptions options,
Handler<AsyncResult<Boolean>> resultHandler) |
ConsulService |
ConsulService.putValueWithOptions(String key,
String value,
KeyValueOptions options,
Handler<AsyncResult<Boolean>> resultHandler) |
ConsulClient |
ConsulClient.registerCheck(CheckOptions checkOptions,
Handler<AsyncResult<Void>> resultHandler)
Add a new check to the local agent.
|
ConsulService |
ConsulService.registerCheck(CheckOptions checkOptions,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.registerService(ServiceOptions serviceOptions,
Handler<AsyncResult<Void>> resultHandler)
Adds a new service, with an optional health check, to the local agent.
|
ConsulService |
ConsulService.registerService(ServiceOptions serviceOptions,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.renewSession(String id,
Handler<AsyncResult<Session>> resultHandler)
Renews the given session.
|
ConsulService |
ConsulService.renewSession(String id,
Handler<AsyncResult<Session>> resultHandler) |
ConsulClient |
ConsulClient.transaction(TxnRequest request,
Handler<AsyncResult<TxnResponse>> resultHandler)
Manages multiple operations inside a single, atomic transaction.
|
ConsulService |
ConsulService.transaction(TxnRequest request,
Handler<AsyncResult<TxnResponse>> resultHandler) |
ConsulClient |
ConsulClient.updateAclToken(AclToken token,
Handler<AsyncResult<String>> idHandler)
Update Acl token
|
ConsulService |
ConsulService.updateAclToken(AclToken token,
Handler<AsyncResult<String>> idHandler) |
ConsulClient |
ConsulClient.updateCheck(String checkId,
CheckStatus status,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to given status.
|
ConsulService |
ConsulService.updateCheck(String checkId,
CheckStatus status,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.updateCheckWithNote(String checkId,
CheckStatus status,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to given status.
|
ConsulService |
ConsulService.updateCheckWithNote(String checkId,
CheckStatus status,
String note,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.updatePreparedQuery(PreparedQueryDefinition definition,
Handler<AsyncResult<Void>> resultHandler) |
ConsulService |
ConsulService.updatePreparedQuery(PreparedQueryDefinition definition,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.warnCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "warning".
|
ConsulService |
ConsulService.warnCheck(String checkId,
Handler<AsyncResult<Void>> resultHandler) |
ConsulClient |
ConsulClient.warnCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler)
Set status of the check to "warning".
|
ConsulService |
ConsulService.warnCheckWithNote(String checkId,
String note,
Handler<AsyncResult<Void>> resultHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
TcpEventBusBridge.close(Handler<AsyncResult<Void>> handler)
Close the current socket.
|
TcpEventBusBridge |
TcpEventBusBridge.listen(Handler<AsyncResult<TcpEventBusBridge>> handler)
Listen on default port 7000 with a handler to report the state of the socket listen operation.
|
TcpEventBusBridge |
TcpEventBusBridge.listen(int port,
Handler<AsyncResult<TcpEventBusBridge>> handler)
Listen on specific port
|
TcpEventBusBridge |
TcpEventBusBridge.listen(int port,
String address,
Handler<AsyncResult<TcpEventBusBridge>> handler)
Listen on specific port and bind to specific address
|
| Modifier and Type | Method and Description |
|---|---|
HealthChecks |
HealthChecks.invoke(String name,
Handler<AsyncResult<JsonObject>> resultHandler)
Invokes the registered procedure with the given name and sub-procedures.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
HttpServiceFactory.doRequest(HttpClient client,
File file,
URI url,
File signatureFile,
URI signatureURL,
Handler<AsyncResult<io.vertx.ext.httpservicefactory.HttpServiceFactory.Result>> handler) |
| Modifier and Type | Method and Description |
|---|---|
MailService |
MailService.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler) |
MailClient |
MailClient.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler)
send a single mail via MailClient
|
| Modifier and Type | Method and Description |
|---|---|
MongoClient |
MongoClient.bulkWrite(String collection,
List<BulkOperation> operations,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
Execute a bulk operation.
|
MongoService |
MongoService.bulkWrite(String collection,
List<BulkOperation> operations,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler) |
MongoClient |
MongoClient.bulkWriteWithOptions(String collection,
List<BulkOperation> operations,
BulkWriteOptions bulkWriteOptions,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
Execute a bulk operation with the specified write options.
|
MongoService |
MongoService.bulkWriteWithOptions(String collection,
List<BulkOperation> operations,
BulkWriteOptions bulkWriteOptions,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler) |
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoService |
MongoService.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler) |
MongoClient |
MongoClient.createCollection(String collectionName,
Handler<AsyncResult<Void>> resultHandler)
Create a new collection
|
MongoService |
MongoService.createCollection(String collectionName,
Handler<AsyncResult<Void>> resultHandler) |
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoService |
MongoService.createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler) |
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoService |
MongoService.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler) |
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
MongoService |
MongoService.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler) |
MongoClient |
MongoClient.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name filtered by specified query.
|
MongoService |
MongoService.distinctWithQuery(String collection,
String fieldName,
String resultClassname,
JsonObject query,
Handler<AsyncResult<JsonArray>> resultHandler) |
MongoClient |
MongoClient.dropCollection(String collection,
Handler<AsyncResult<Void>> resultHandler)
Drop a collection
|
MongoService |
MongoService.dropCollection(String collection,
Handler<AsyncResult<Void>> resultHandler) |
MongoClient |
MongoClient.dropIndex(String collection,
String indexName,
Handler<AsyncResult<Void>> resultHandler)
Drops the index given its name.
|
MongoService |
MongoService.dropIndex(String collection,
String indexName,
Handler<AsyncResult<Void>> resultHandler) |
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoService |
MongoService.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler) |
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoService |
MongoService.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoService |
MongoService.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
MongoService |
MongoService.findOneAndDeleteWithOptions(String collection,
JsonObject query,
FindOptions findOptions,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoService |
MongoService.findOneAndReplace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and replace it.
|
MongoService |
MongoService.findOneAndReplaceWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoService |
MongoService.findOneAndUpdate(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and update it.
|
MongoService |
MongoService.findOneAndUpdateWithOptions(String collection,
JsonObject query,
JsonObject update,
FindOptions findOptions,
UpdateOptions updateOptions,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoService |
MongoService.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler) |
MongoClient |
MongoClient.getCollections(Handler<AsyncResult<List<String>>> resultHandler)
Get a list of all collections in the database.
|
MongoService |
MongoService.getCollections(Handler<AsyncResult<List<String>>> resultHandler) |
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
MongoService |
MongoService.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler) |
MongoClient |
MongoClient.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection with the specified write option
|
MongoService |
MongoService.insertWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler) |
MongoClient |
MongoClient.listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler)
Get all the indexes in this collection.
|
MongoService |
MongoService.listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler) |
MongoClient |
MongoClient.remove(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.remove(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection and return the handler with MongoClientDeleteResult result
|
MongoService |
MongoService.removeDocument(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler) |
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with MongoClientDeleteResult result
|
MongoService |
MongoService.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler) |
MongoClient |
MongoClient.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
MongoService |
MongoService.removeDocumentsWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler) |
MongoClient |
MongoClient.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove a single matching document from a collection with the specified write option and return the handler with MongoClientDeleteResult result
|
MongoService |
MongoService.removeDocumentWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler) |
MongoClient |
MongoClient.removeOne(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.removeOne(String collection,
JsonObject query,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.removeOneWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.removeOneWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.removeWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.removeWithOptions(String collection,
JsonObject query,
WriteOption writeOption,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.replace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.replace(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
MongoService |
MongoService.replaceDocuments(String collection,
JsonObject query,
JsonObject replace,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler) |
MongoClient |
MongoClient.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Replace matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
MongoService |
MongoService.replaceDocumentsWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler) |
MongoClient |
MongoClient.replaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.replaceWithOptions(String collection,
JsonObject query,
JsonObject replace,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
MongoService |
MongoService.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler) |
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
MongoService |
MongoService.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler) |
MongoClient |
MongoClient.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection with the specified write option
|
MongoService |
MongoService.saveWithOptions(String collection,
JsonObject document,
WriteOption writeOption,
Handler<AsyncResult<String>> resultHandler) |
MongoClient |
MongoClient.update(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.update(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoClient |
MongoClient.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection and return the handler with MongoClientUpdateResult result
|
MongoService |
MongoService.updateCollection(String collection,
JsonObject query,
JsonObject update,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler) |
MongoClient |
MongoClient.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler)
Update matching documents in the specified collection, specifying options and return the handler with MongoClientUpdateResult result
|
MongoService |
MongoService.updateCollectionWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<MongoClientUpdateResult>> resultHandler) |
MongoClient |
MongoClient.updateWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
MongoService |
MongoService.updateWithOptions(String collection,
JsonObject query,
JsonObject update,
UpdateOptions options,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
ReactiveWriteStream<T> |
ReactiveWriteStream.write(T data,
Handler<AsyncResult<Void>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
ShellServer.close(Handler<AsyncResult<Void>> completionHandler)
Close the shell server, this is an asynchronous close.
|
ShellServer |
ShellServer.listen(Handler<AsyncResult<Void>> listenHandler)
Start the shell service, this is an asynchronous start.
|
void |
ShellService.start(Handler<AsyncResult<Void>> startHandler)
Start the shell service, this is an asynchronous start.
|
void |
ShellService.stop(Handler<AsyncResult<Void>> stopHandler)
Stop the shell service, this is an asynchronous start.
|
| Modifier and Type | Method and Description |
|---|---|
CommandRegistry |
CommandRegistry.registerCommand(Class<? extends AnnotatedCommand> command,
Handler<AsyncResult<Command>> completionHandler)
Register a single command.
|
CommandRegistry |
CommandRegistry.registerCommand(Command command,
Handler<AsyncResult<Command>> completionHandler)
Register a command
|
CommandRegistry |
CommandRegistry.registerCommands(List<Command> commands,
Handler<AsyncResult<List<Command>>> completionHandler)
Register a list of commands.
|
CommandRegistry |
CommandRegistry.unregisterCommand(String commandName,
Handler<AsyncResult<Void>> completionHandler)
Unregister a command.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CommandResolverFactory.resolver(Vertx vertx,
Handler<AsyncResult<CommandResolver>> resolveHandler)
Obtain a command resolver for a Vert.x instance.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TermServer.close(Handler<AsyncResult<Void>> completionHandler)
Like
TermServer.close() but supplying a handler that will be notified when close is complete. |
TermServer |
TermServer.listen(Handler<AsyncResult<TermServer>> listenHandler)
Bind the term server, the
TermServer.termHandler(Handler) must be set before. |
| Modifier and Type | Method and Description |
|---|---|
SQLConnection |
SQLConnection.batch(List<String> sqlStatements,
Handler<AsyncResult<List<Integer>>> handler)
Batch simple SQL strings and execute the batch where the async result contains a array of Integers.
|
SQLConnection |
SQLConnection.batchCallableWithParams(String sqlStatement,
List<JsonArray> inArgs,
List<JsonArray> outArgs,
Handler<AsyncResult<List<Integer>>> handler)
Batch a callable statement with all entries from the args list.
|
SQLConnection |
SQLConnection.batchWithParams(String sqlStatement,
List<JsonArray> args,
Handler<AsyncResult<List<Integer>>> handler)
Batch a prepared statement with all entries from the args list.
|
SQLConnection |
SQLConnection.call(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
default SQLClient |
SQLClient.call(String sql,
Handler<AsyncResult<ResultSet>> handler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.call(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLConnection |
SQLConnection.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
default SQLClient |
SQLClient.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> handler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
SQLOperations |
SQLOperations.callWithParams(String sql,
JsonArray params,
JsonArray outputs,
Handler<AsyncResult<ResultSet>> resultHandler)
Calls the given SQL
PROCEDURE which returns the result from the procedure. |
void |
SQLRowStream.close(Handler<AsyncResult<Void>> handler)
Closes the stream/underlying cursor(s).
|
void |
SQLConnection.close(Handler<AsyncResult<Void>> handler)
Closes the connection.
|
void |
SQLClient.close(Handler<AsyncResult<Void>> handler)
Close the client and release all resources.
|
SQLConnection |
SQLConnection.commit(Handler<AsyncResult<Void>> handler)
Commits all changes made since the previous commit/rollback.
|
SQLConnection |
SQLConnection.execute(String sql,
Handler<AsyncResult<Void>> resultHandler)
Executes the given SQL statement
|
SQLClient |
SQLClient.getConnection(Handler<AsyncResult<SQLConnection>> handler)
Returns a connection that can be used to perform SQL operations on.
|
SQLConnection |
SQLConnection.getTransactionIsolation(Handler<AsyncResult<TransactionIsolation>> handler)
Attempts to return the transaction isolation level for this Connection object to the one given.
|
SQLConnection |
SQLConnection.query(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT statement which returns the results of the query. |
default SQLClient |
SQLClient.query(String sql,
Handler<AsyncResult<ResultSet>> handler)
Execute a single SQL statement, this method acquires a connection from the the pool and executes the SQL
statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.query(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT statement which returns the results of the query. |
default SQLOperations |
SQLOperations.querySingle(String sql,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement that returns a single SQL row.
|
default SQLOperations |
SQLOperations.querySingleWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<JsonArray>> handler)
Execute a one shot SQL statement with arguments that returns a single SQL row.
|
SQLConnection |
SQLConnection.queryStream(String sql,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
default SQLClient |
SQLClient.queryStream(String sql,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStream(String sql,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
default SQLClient |
SQLClient.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLOperations |
SQLOperations.queryStreamWithParams(String sql,
JsonArray params,
Handler<AsyncResult<SQLRowStream>> handler)
Executes the given SQL
SELECT statement which returns the results of the query as a read stream. |
SQLConnection |
SQLConnection.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
default SQLClient |
SQLClient.queryWithParams(String sql,
JsonArray arguments,
Handler<AsyncResult<ResultSet>> handler)
Execute a single SQL prepared statement, this method acquires a connection from the the pool and executes the SQL
prepared statement and returns it back after the execution.
|
SQLOperations |
SQLOperations.queryWithParams(String sql,
JsonArray params,
Handler<AsyncResult<ResultSet>> resultHandler)
Executes the given SQL
SELECT prepared statement which returns the results of the query. |
SQLConnection |
SQLConnection.rollback(Handler<AsyncResult<Void>> handler)
Rolls back all changes made since the previous commit/rollback.
|
SQLConnection |
SQLConnection.setAutoCommit(boolean autoCommit,
Handler<AsyncResult<Void>> resultHandler)
Sets the auto commit flag for this connection.
|
SQLConnection |
SQLConnection.setTransactionIsolation(TransactionIsolation isolation,
Handler<AsyncResult<Void>> handler)
Attempts to change the transaction isolation level for this Connection object to the one given.
|
SQLConnection |
SQLConnection.update(String sql,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given SQL statement which may be an
INSERT, UPDATE, or DELETE
statement. |
default SQLClient |
SQLClient.update(String sql,
Handler<AsyncResult<UpdateResult>> handler)
Executes the given SQL statement which may be an
INSERT, UPDATE, or DELETE
statement. |
SQLOperations |
SQLOperations.update(String sql,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given SQL statement which may be an
INSERT, UPDATE, or DELETE
statement. |
SQLConnection |
SQLConnection.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT, UPDATE, or DELETE
statement with the given parameters |
default SQLClient |
SQLClient.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> handler)
Executes the given prepared statement which may be an
INSERT, UPDATE, or DELETE
statement with the given parameters |
SQLOperations |
SQLOperations.updateWithParams(String sql,
JsonArray params,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given prepared statement which may be an
INSERT, UPDATE, or DELETE
statement with the given parameters |
| Modifier and Type | Method and Description |
|---|---|
void |
StompServer.close(Handler<AsyncResult<Void>> completionHandler)
Closes the server.
|
StompClient |
StompClient.connect(Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server using the host and port configured in the client's options.
|
StompClient |
StompClient.connect(int port,
String host,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
StompClient.connect(int port,
String host,
NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompClient |
StompClient.connect(NetClient net,
Handler<AsyncResult<StompClientConnection>> resultHandler)
Connects to the server.
|
StompServer |
StompServer.listen(Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server default port (61613) and network interface (
0.0.0.0). |
StompServer |
StompServer.listen(int port,
Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server to the given port.
|
StompServer |
StompServer.listen(int port,
String host,
Handler<AsyncResult<StompServer>> handler)
Connects the STOMP server to the given port / interface.
|
StompServerHandler |
StompServerHandler.onAuthenticationRequest(StompServerConnection connection,
String login,
String passcode,
Handler<AsyncResult<Boolean>> handler)
Called when the client connects to a server requiring authentication.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> T |
Sync.awaitResult(java.util.function.Consumer<Handler<AsyncResult<T>>> consumer)
Invoke an asynchronous operation and obtain the result synchronous.
|
static <T> T |
Sync.awaitResult(java.util.function.Consumer<Handler<AsyncResult<T>>> consumer,
long timeout)
Invoke an asynchronous operation and obtain the result synchronous.
|
| Modifier and Type | Method and Description |
|---|---|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertFailure()
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a failed result it completes the async operation.
When the returned handler is called back with a succeeded result it fails the test.
|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertFailure(Handler<Throwable> causeHandler)
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a failed result it completes the async operation.
When the returned handler is called back with a succeeded result it fails the test.
|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertSuccess()
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a succeeded result it completes the async operation.
When the returned handler is called back with a failed result it fails the test with the cause of the failure.
|
<T> Handler<AsyncResult<T>> |
TestContext.asyncAssertSuccess(Handler<T> resultHandler)
Creates and returns a new async handler, the returned handler controls the completion of the test.
When the returned handler is called back with a succeeded result it invokes the
resultHandler argument
with the async result. |
| Modifier and Type | Method and Description |
|---|---|
void |
Completion.handler(Handler<AsyncResult<T>> completionHandler)
Completion handler to receive a completion signal when this completions completes.
|
| Modifier and Type | Method and Description |
|---|---|
int |
RoutingContext.addEndHandler(Handler<AsyncResult<Void>> handler)
Add an end handler for the request/response context.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Create a new OpenAPI3RouterFactory
|
static void |
OpenAPI3RouterFactory.create(Vertx vertx,
String url,
List<JsonObject> auth,
Handler<AsyncResult<OpenAPI3RouterFactory>> handler)
Create a new OpenAPI3RouterFactory
|
| Modifier and Type | Method and Description |
|---|---|
void |
HttpRequest.send(Handler<AsyncResult<HttpResponse<T>>> handler)
Send a request, the
handler will receive the response as an HttpResponse. |
void |
HttpRequest.sendBuffer(Buffer body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body buffer. |
void |
HttpRequest.sendForm(MultiMap body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body multimap encoded as form and the content type
set to application/x-www-form-urlencoded. |
void |
HttpRequest.sendJson(Object body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body object encoded as json and the content type
set to application/json. |
void |
HttpRequest.sendJsonObject(JsonObject body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body object encoded as json and the content type
set to application/json. |
void |
HttpRequest.sendMultipartForm(MultipartForm body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body multimap encoded as form and the content type
set to multipart/form-data. |
void |
HttpRequest.sendStream(ReadStream<Buffer> body,
Handler<AsyncResult<HttpResponse<T>>> handler)
Like
HttpRequest.send(Handler) but with an HTTP request body stream. |
| Modifier and Type | Method and Description |
|---|---|
void |
BodyCodec.create(Handler<AsyncResult<BodyStream<T>>> handler)
Create the
BodyStream. |
| Modifier and Type | Method and Description |
|---|---|
default void |
TemplateEngine.render(JsonObject context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
void |
TemplateEngine.render(Map<String,Object> context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Render the template.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AuthHandler.authorize(User user,
Handler<AsyncResult<Void>> handler)
Authorizes the given user against all added authorities.
|
SessionHandler |
SessionHandler.flush(RoutingContext ctx,
Handler<AsyncResult<Void>> handler)
Flush a context session earlier to the store, this will allow the end user to have full control on the event of
a failure at the store level.
|
void |
AuthHandler.parseCredentials(RoutingContext context,
Handler<AsyncResult<JsonObject>> handler)
Parses the credentials from the request into a JsonObject.
|
| Modifier and Type | Method and Description |
|---|---|
SockJSSocket |
SockJSSocket.write(Buffer data,
Handler<AsyncResult<Void>> handler) |
default SockJSSocket |
SockJSSocket.write(String data,
Handler<AsyncResult<Void>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
SessionStore.clear(Handler<AsyncResult<Void>> resultHandler)
Remove all sessions from the store.
|
void |
SessionStore.delete(String id,
Handler<AsyncResult<Void>> resultHandler)
Delete the session with the specified ID.
|
void |
SessionStore.get(String cookieValue,
Handler<AsyncResult<Session>> resultHandler)
Get the session with the specified ID.
|
void |
SessionStore.put(Session session,
Handler<AsyncResult<Void>> resultHandler)
Add a session with the specified ID.
|
void |
SessionStore.size(Handler<AsyncResult<Integer>> resultHandler)
Get the number of sessions in the store.
|
| Modifier and Type | Method and Description |
|---|---|
default void |
TemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
FreeMarkerTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
PebbleTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
JadeTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
ThymeleafTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
HandlebarsTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
RockerTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
MVELTemplateEngine.render(RoutingContext context,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
default void |
TemplateEngine.render(RoutingContext context,
String templateDirectory,
String templateFileName,
Handler<AsyncResult<Buffer>> handler)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
GrpcUniExchange<O,I> |
GrpcUniExchange.handler(Handler<AsyncResult<I>> handler) |
VertxServer |
VertxServer.shutdown(Handler<AsyncResult<Void>> completionHandler) |
VertxServer |
VertxServer.start(Handler<AsyncResult<Void>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
<T> Handler<AsyncResult<T>> |
VertxTestContext.completing()
Create an asynchronous result handler that expects a success to then complete the test context.
|
<T> Handler<AsyncResult<T>> |
VertxTestContext.failing()
Create an asynchronous result handler that expects a failure.
|
<T> Handler<AsyncResult<T>> |
VertxTestContext.failing(Handler<Throwable> nextHandler)
Create an asynchronous result handler that expects a failure, and passes the exception to another handler.
|
<T> Handler<AsyncResult<T>> |
VertxTestContext.succeeding()
Create an asynchronous result handler that expects a success.
|
<T> Handler<AsyncResult<T>> |
VertxTestContext.succeeding(Handler<T> nextHandler)
Create an asynchronous result handler that expects a success, and passes the value to another handler.
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaAdminClient.alterConfigs(Map<ConfigResource,Config> configs,
Handler<AsyncResult<Void>> completionHandler)
Update the configuration for the specified resources with the default options
|
void |
KafkaAdminClient.alterConsumerGroupOffsets(String groupId,
Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Void>> completionHandler)
Alter committed offsets for a set of partitions in a consumer group.
|
void |
KafkaAdminClient.close(Handler<AsyncResult<Void>> completionHandler)
Close the admin client
|
void |
KafkaAdminClient.close(long timeout,
Handler<AsyncResult<Void>> completionHandler)
Close the admin client
|
void |
KafkaAdminClient.createTopics(List<NewTopic> topics,
Handler<AsyncResult<Void>> completionHandler)
Creates a batch of new Kafka topics
|
void |
KafkaAdminClient.deleteConsumerGroupOffsets(String groupId,
Set<TopicPartition> partitions,
Handler<AsyncResult<Void>> completionHandler)
Delete committed offsets for a set of partitions in a consumer group.
|
void |
KafkaAdminClient.deleteConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Void>> completionHandler)
Delete consumer groups from the cluster.
|
void |
KafkaAdminClient.deleteTopics(List<String> topicNames,
Handler<AsyncResult<Void>> completionHandler)
Deletes a batch of Kafka topics
|
void |
KafkaAdminClient.describeCluster(Handler<AsyncResult<ClusterDescription>> completionHandler)
Describe the nodes in the cluster with the default options
|
void |
KafkaAdminClient.describeConfigs(List<ConfigResource> configResources,
Handler<AsyncResult<Map<ConfigResource,Config>>> completionHandler)
Get the configuration for the specified resources with the default options
|
void |
KafkaAdminClient.describeConsumerGroups(List<String> groupIds,
Handler<AsyncResult<Map<String,ConsumerGroupDescription>>> completionHandler)
Describe some group ids in the cluster, with the default options
|
void |
KafkaAdminClient.describeTopics(List<String> topicNames,
Handler<AsyncResult<Map<String,TopicDescription>>> completionHandler)
Describe some topics in the cluster, with the default options.
|
default void |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
void |
KafkaAdminClient.listConsumerGroupOffsets(String groupId,
ListConsumerGroupOffsetsOptions options,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
List the consumer group offsets available in the cluster.
|
void |
KafkaAdminClient.listConsumerGroups(Handler<AsyncResult<List<ConsumerGroupListing>>> completionHandler)
Get the the consumer groups available in the cluster with the default options
|
void |
KafkaAdminClient.listOffsets(Map<TopicPartition,OffsetSpec> topicPartitionOffsets,
Handler<AsyncResult<Map<TopicPartition,ListOffsetsResultInfo>>> completionHandler)
List the offsets available for a set of partitions.
|
void |
KafkaAdminClient.listTopics(Handler<AsyncResult<Set<String>>> completionHandler)
List the topics available in the cluster with the default options.
|
| Modifier and Type | Method and Description |
|---|---|
KafkaReadStream<K,V> |
KafkaReadStream.assign(Set<org.apache.kafka.common.TopicPartition> partitions,
Handler<AsyncResult<Void>> completionHandler)
Manually assign a set of partitions to this consumer.
|
KafkaConsumer<K,V> |
KafkaConsumer.assign(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Manually assign a list of partition to this consumer.
|
KafkaConsumer<K,V> |
KafkaConsumer.assign(TopicPartition topicPartition,
Handler<AsyncResult<Void>> completionHandler)
Manually assign a partition to this consumer.
|
KafkaReadStream<K,V> |
KafkaReadStream.assignment(Handler<AsyncResult<Set<org.apache.kafka.common.TopicPartition>>> handler)
Get the set of partitions currently assigned to this consumer.
|
KafkaConsumer<K,V> |
KafkaConsumer.assignment(Handler<AsyncResult<Set<TopicPartition>>> handler)
Get the set of partitions currently assigned to this consumer.
|
void |
KafkaReadStream.beginningOffsets(Set<org.apache.kafka.common.TopicPartition> topicPartitions,
Handler<AsyncResult<Map<org.apache.kafka.common.TopicPartition,Long>>> handler)
Get the first offset for the given partitions.
|
void |
KafkaConsumer.beginningOffsets(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Map<TopicPartition,Long>>> handler)
Get the first offset for the given partitions.
|
void |
KafkaReadStream.beginningOffsets(org.apache.kafka.common.TopicPartition topicPartition,
Handler<AsyncResult<Long>> handler)
Get the first offset for the given partition.
|
void |
KafkaConsumer.beginningOffsets(TopicPartition topicPartition,
Handler<AsyncResult<Long>> handler)
Get the first offset for the given partitions.
|
void |
KafkaReadStream.close(Handler<AsyncResult<Void>> completionHandler)
Close the stream
|
void |
KafkaConsumer.close(Handler<AsyncResult<Void>> completionHandler)
Close the consumer
|
void |
KafkaReadStream.commit(Handler<AsyncResult<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>>> completionHandler)
Commit current offsets for all the subscribed list of topics and partition.
|
void |
KafkaConsumer.commit(Handler<AsyncResult<Void>> completionHandler)
Commit current offsets for all the subscribed list of topics and partition.
|
void |
KafkaReadStream.commit(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets,
Handler<AsyncResult<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata>>> completionHandler)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
void |
KafkaConsumer.commit(Map<TopicPartition,OffsetAndMetadata> offsets,
Handler<AsyncResult<Map<TopicPartition,OffsetAndMetadata>>> completionHandler)
Commit the specified offsets for the specified list of topics and partitions to Kafka.
|
void |
KafkaReadStream.committed(org.apache.kafka.common.TopicPartition topicPartition,
Handler<AsyncResult<org.apache.kafka.clients.consumer.OffsetAndMetadata>> handler)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
void |
KafkaConsumer.committed(TopicPartition topicPartition,
Handler<AsyncResult<OffsetAndMetadata>> handler)
Get the last committed offset for the given partition (whether the commit happened by this process or another).
|
void |
KafkaReadStream.endOffsets(Set<org.apache.kafka.common.TopicPartition> topicPartitions,
Handler<AsyncResult<Map<org.apache.kafka.common.TopicPartition,Long>>> handler)
Get the last offset for the given partitions.
|
void |
KafkaConsumer.endOffsets(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Map<TopicPartition,Long>>> handler)
Get the last offset for the given partitions.
|
void |
KafkaReadStream.endOffsets(org.apache.kafka.common.TopicPartition topicPartition,
Handler<AsyncResult<Long>> handler)
Get the last offset for the given partition.
|
void |
KafkaConsumer.endOffsets(TopicPartition topicPartition,
Handler<AsyncResult<Long>> handler)
Get the last offset for the given partition.
|
KafkaReadStream<K,V> |
KafkaReadStream.listTopics(Handler<AsyncResult<Map<String,List<org.apache.kafka.common.PartitionInfo>>>> handler)
Get metadata about partitions for all topics that the user is authorized to view.
|
KafkaConsumer<K,V> |
KafkaConsumer.listTopics(Handler<AsyncResult<Map<String,List<PartitionInfo>>>> handler)
Get metadata about partitions for all topics that the user is authorized to view.
|
void |
KafkaReadStream.offsetsForTimes(Map<org.apache.kafka.common.TopicPartition,Long> topicPartitionTimestamps,
Handler<AsyncResult<Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndTimestamp>>> handler)
Look up the offsets for the given partitions by timestamp.
|
void |
KafkaConsumer.offsetsForTimes(Map<TopicPartition,Long> topicPartitionTimestamps,
Handler<AsyncResult<Map<TopicPartition,OffsetAndTimestamp>>> handler)
Look up the offsets for the given partitions by timestamp.
|
void |
KafkaReadStream.offsetsForTimes(org.apache.kafka.common.TopicPartition topicPartition,
long timestamp,
Handler<AsyncResult<org.apache.kafka.clients.consumer.OffsetAndTimestamp>> handler)
* Look up the offset for the given partition by timestamp.
|
void |
KafkaConsumer.offsetsForTimes(TopicPartition topicPartition,
Long timestamp,
Handler<AsyncResult<OffsetAndTimestamp>> handler)
Look up the offset for the given partition by timestamp.
|
KafkaReadStream<K,V> |
KafkaReadStream.partitionsFor(String topic,
Handler<AsyncResult<List<org.apache.kafka.common.PartitionInfo>>> handler)
Get metadata about the partitions for a given topic.
|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get metadata about the partitions for a given topic.
|
KafkaReadStream<K,V> |
KafkaReadStream.pause(Set<org.apache.kafka.common.TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Suspend fetching from the requested partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.pause(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Suspend fetching from the requested partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.pause(TopicPartition topicPartition,
Handler<AsyncResult<Void>> completionHandler)
Suspend fetching from the requested partition.
|
void |
KafkaReadStream.paused(Handler<AsyncResult<Set<org.apache.kafka.common.TopicPartition>>> handler)
Get the set of partitions that were previously paused by a call to
KafkaReadStream.pause(Set). |
void |
KafkaConsumer.paused(Handler<AsyncResult<Set<TopicPartition>>> handler)
Get the set of partitions that were previously paused by a call to pause(Set).
|
void |
KafkaReadStream.poll(java.time.Duration timeout,
Handler<AsyncResult<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>>> handler)
Executes a poll for getting messages from Kafka.
|
void |
KafkaConsumer.poll(java.time.Duration timeout,
Handler<AsyncResult<KafkaConsumerRecords<K,V>>> handler)
Executes a poll for getting messages from Kafka.
|
void |
KafkaReadStream.poll(long timeout,
Handler<AsyncResult<org.apache.kafka.clients.consumer.ConsumerRecords<K,V>>> handler)
Deprecated.
|
void |
KafkaConsumer.poll(long timeout,
Handler<AsyncResult<KafkaConsumerRecords<K,V>>> handler)
Deprecated.
|
void |
KafkaReadStream.position(org.apache.kafka.common.TopicPartition partition,
Handler<AsyncResult<Long>> handler)
Get the offset of the next record that will be fetched (if a record with that offset exists).
|
void |
KafkaConsumer.position(TopicPartition partition,
Handler<AsyncResult<Long>> handler)
Get the offset of the next record that will be fetched (if a record with that offset exists).
|
KafkaReadStream<K,V> |
KafkaReadStream.resume(Set<org.apache.kafka.common.TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Resume specified partitions which have been paused with pause.
|
KafkaConsumer<K,V> |
KafkaConsumer.resume(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Resume specified partitions which have been paused with pause.
|
KafkaConsumer<K,V> |
KafkaConsumer.resume(TopicPartition topicPartition,
Handler<AsyncResult<Void>> completionHandler)
Resume specified partition which have been paused with pause.
|
KafkaReadStream<K,V> |
KafkaReadStream.seek(org.apache.kafka.common.TopicPartition topicPartition,
long offset,
Handler<AsyncResult<Void>> completionHandler)
Overrides the fetch offsets that the consumer will use on the next poll.
|
KafkaConsumer<K,V> |
KafkaConsumer.seek(TopicPartition topicPartition,
long offset,
Handler<AsyncResult<Void>> completionHandler)
Overrides the fetch offsets that the consumer will use on the next poll.
|
KafkaReadStream<K,V> |
KafkaReadStream.seekToBeginning(Set<org.apache.kafka.common.TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Seek to the first offset for each of the given partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.seekToBeginning(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Seek to the first offset for each of the given partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.seekToBeginning(TopicPartition topicPartition,
Handler<AsyncResult<Void>> completionHandler)
Seek to the first offset for each of the given partition.
|
KafkaReadStream<K,V> |
KafkaReadStream.seekToEnd(Set<org.apache.kafka.common.TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Seek to the last offset for each of the given partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.seekToEnd(Set<TopicPartition> topicPartitions,
Handler<AsyncResult<Void>> completionHandler)
Seek to the last offset for each of the given partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.seekToEnd(TopicPartition topicPartition,
Handler<AsyncResult<Void>> completionHandler)
Seek to the last offset for each of the given partition.
|
KafkaReadStream<K,V> |
KafkaReadStream.subscribe(Pattern pattern,
Handler<AsyncResult<Void>> completionHandler)
Subscribe to all topics matching specified pattern to get dynamically assigned partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.subscribe(Pattern pattern,
Handler<AsyncResult<Void>> completionHandler)
Subscribe to all topics matching specified pattern to get dynamically assigned partitions.
|
KafkaReadStream<K,V> |
KafkaReadStream.subscribe(Set<String> topics,
Handler<AsyncResult<Void>> completionHandler)
Subscribe to the given list of topics to get dynamically assigned partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.subscribe(Set<String> topics,
Handler<AsyncResult<Void>> completionHandler)
Subscribe to the given list of topics to get dynamically assigned partitions.
|
KafkaConsumer<K,V> |
KafkaConsumer.subscribe(String topic,
Handler<AsyncResult<Void>> completionHandler)
Subscribe to the given topic to get dynamically assigned partitions.
|
KafkaReadStream<K,V> |
KafkaReadStream.subscription(Handler<AsyncResult<Set<String>>> handler)
Get the current subscription.
|
KafkaConsumer<K,V> |
KafkaConsumer.subscription(Handler<AsyncResult<Set<String>>> handler)
Get the current subscription.
|
KafkaReadStream<K,V> |
KafkaReadStream.unsubscribe(Handler<AsyncResult<Void>> completionHandler)
Unsubscribe from topics currently subscribed with subscribe.
|
KafkaConsumer<K,V> |
KafkaConsumer.unsubscribe(Handler<AsyncResult<Void>> completionHandler)
Unsubscribe from topics currently subscribed with subscribe.
|
| Modifier and Type | Method and Description |
|---|---|
void |
KafkaProducer.close(Handler<AsyncResult<Void>> completionHandler)
Close the producer
|
void |
KafkaWriteStream.close(Handler<AsyncResult<Void>> completionHandler)
Close the stream
|
void |
KafkaProducer.close(long timeout,
Handler<AsyncResult<Void>> completionHandler)
Close the producer
|
void |
KafkaWriteStream.close(long timeout,
Handler<AsyncResult<Void>> completionHandler)
Close the stream
|
KafkaProducer<K,V> |
KafkaProducer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get the partition metadata for the give topic.
|
KafkaWriteStream<K,V> |
KafkaWriteStream.partitionsFor(String topic,
Handler<AsyncResult<List<org.apache.kafka.common.PartitionInfo>>> handler)
Get the partition metadata for the give topic.
|
KafkaProducer<K,V> |
KafkaProducer.send(KafkaProducerRecord<K,V> record,
Handler<AsyncResult<RecordMetadata>> handler)
Asynchronously write a record to a topic
|
KafkaWriteStream<K,V> |
KafkaWriteStream.send(org.apache.kafka.clients.producer.ProducerRecord<K,V> record,
Handler<AsyncResult<org.apache.kafka.clients.producer.RecordMetadata>> handler)
Asynchronously write a record to a topic
|
KafkaProducer<K,V> |
KafkaProducer.write(KafkaProducerRecord<K,V> data,
Handler<AsyncResult<Void>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
MqttServer.close(Handler<AsyncResult<Void>> completionHandler)
Close the server supplying an handler that will be called when the server is actually closed (or has failed).
|
MqttClient |
MqttClient.connect(int port,
String host,
Handler<AsyncResult<MqttConnAckMessage>> connectHandler)
Connects to an MQTT server calling connectHandler after connection
|
MqttClient |
MqttClient.connect(int port,
String host,
String serverName,
Handler<AsyncResult<MqttConnAckMessage>> connectHandler)
Connects to an MQTT server calling connectHandler after connection
|
MqttClient |
MqttClient.disconnect(Handler<AsyncResult<Void>> disconnectHandler)
Disconnects from the MQTT server calling disconnectHandler after disconnection
|
MqttServer |
MqttServer.listen(Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections using the specified options
through the constructor
|
MqttServer |
MqttServer.listen(int port,
Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port specified but on
"0.0.0.0" as host.
|
MqttServer |
MqttServer.listen(int port,
String host,
Handler<AsyncResult<MqttServer>> listenHandler)
Start the server listening for incoming connections on the port and host specified
It ignores any options specified through the constructor
|
MqttClient |
MqttClient.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server
|
MqttEndpoint |
MqttEndpoint.publish(String topic,
Buffer payload,
io.netty.handler.codec.mqtt.MqttQoS qosLevel,
boolean isDup,
boolean isRetain,
int messageId,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
MqttClient |
MqttClient.subscribe(Map<String,Integer> topics,
Handler<AsyncResult<Integer>> subscribeSentHandler)
Subscribes to the topic and adds a handler which will be called after the request is sent
|
MqttClient |
MqttClient.subscribe(String topic,
int qos,
Handler<AsyncResult<Integer>> subscribeSentHandler)
Subscribes to the topic with a specified QoS level
|
MqttClient |
MqttClient.unsubscribe(String topic,
Handler<AsyncResult<Integer>> unsubscribeSentHandler)
Unsubscribe from receiving messages on given topic
|
| Modifier and Type | Method and Description |
|---|---|
MySQLConnection |
MySQLConnection.changeUser(MySQLAuthOptions options,
Handler<AsyncResult<Void>> handler)
Send a CHANGE_USER command to change the user of the current connection, this operation will also reset connection state.
|
static void |
MySQLConnection.connect(Vertx vertx,
MySQLConnectOptions connectOptions,
Handler<AsyncResult<MySQLConnection>> handler)
Create a connection to MySQL server with the given
connectOptions. |
static void |
MySQLConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<MySQLConnection>> handler)
Like
MySQLConnection.connect(Vertx, MySQLConnectOptions, Handler) with options build from connectionUri. |
MySQLConnection |
MySQLConnection.debug(Handler<AsyncResult<Void>> handler)
Send a DEBUG command to dump debug information to the server's stdout.
|
MySQLConnection |
MySQLConnection.getInternalStatistics(Handler<AsyncResult<String>> handler)
Send a STATISTICS command to get a human readable string of the server internal status.
|
MySQLConnection |
MySQLConnection.ping(Handler<AsyncResult<Void>> handler)
Send a PING command to check if the server is alive.
|
MySQLConnection |
MySQLConnection.prepare(String sql,
Handler<AsyncResult<PreparedStatement>> handler) |
MySQLConnection |
MySQLConnection.resetConnection(Handler<AsyncResult<Void>> handler)
Send a RESET_CONNECTION command to reset the session state.
|
MySQLConnection |
MySQLConnection.setOption(MySQLSetOption option,
Handler<AsyncResult<Void>> handler)
Send a SET_OPTION command to set options for the current connection.
|
MySQLConnection |
MySQLConnection.specifySchema(String schemaName,
Handler<AsyncResult<Void>> handler)
Send a INIT_DB command to change the default schema of the connection.
|
| Modifier and Type | Method and Description |
|---|---|
PgConnection |
PgConnection.cancelRequest(Handler<AsyncResult<Void>> handler)
Send a request cancellation message to tell the server to cancel processing request in this connection.
|
static void |
PgConnection.connect(Vertx vertx,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from the environment variables. |
static void |
PgConnection.connect(Vertx vertx,
PgConnectOptions options,
Handler<AsyncResult<PgConnection>> handler)
Connects to the database and returns the connection if that succeeds.
|
static void |
PgConnection.connect(Vertx vertx,
String connectionUri,
Handler<AsyncResult<PgConnection>> handler)
Like
PgConnection.connect(Vertx, PgConnectOptions, Handler) with options build from connectionUri. |
PgConnection |
PgConnection.prepare(String sql,
Handler<AsyncResult<PreparedStatement>> handler)
Create a prepared query.
|
| Modifier and Type | Method and Description |
|---|---|
PgSubscriber |
PgSubscriber.connect(Handler<AsyncResult<Void>> handler)
Connect the subscriber to Postgres.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RabbitMQClient.basicAck(long deliveryTag,
boolean multiple,
Handler<AsyncResult<JsonObject>> resultHandler)
Acknowledge one or several received messages.
|
void |
RabbitMQClient.basicCancel(String consumerTag,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
|
void |
RabbitMQClient.basicConsume(String queue,
String address,
boolean autoAck,
Handler<AsyncResult<String>> resultHandler)
Deprecated.
|
void |
RabbitMQClient.basicConsume(String queue,
String address,
boolean autoAck,
Handler<AsyncResult<String>> resultHandler,
Handler<Throwable> errorHandler)
Deprecated.
|
void |
RabbitMQClient.basicConsume(String queue,
String address,
Handler<AsyncResult<String>> resultHandler)
Deprecated.
|
default void |
RabbitMQClient.basicConsumer(String queue,
Handler<AsyncResult<RabbitMQConsumer>> resultHandler) |
void |
RabbitMQClient.basicConsumer(String queue,
QueueOptions options,
Handler<AsyncResult<RabbitMQConsumer>> resultHandler)
Create a consumer with the given
options. |
void |
RabbitMQClient.basicGet(String queue,
boolean autoAck,
Handler<AsyncResult<JsonObject>> resultHandler)
Retrieve a message from a queue using AMQP.Basic.Get
|
void |
RabbitMQClient.basicNack(long deliveryTag,
boolean multiple,
boolean requeue,
Handler<AsyncResult<JsonObject>> resultHandler)
Reject one or several received messages.
|
void |
RabbitMQClient.basicPublish(String exchange,
String routingKey,
JsonObject message,
Handler<AsyncResult<Void>> resultHandler)
Publish a message.
|
default void |
RabbitMQClient.basicQos(int prefetchCount,
boolean global,
Handler<AsyncResult<Void>> resultHandler)
Request a specific prefetchCount "quality of service" settings
for this channel.
|
default void |
RabbitMQClient.basicQos(int prefetchCount,
Handler<AsyncResult<Void>> resultHandler)
Request a specific prefetchCount "quality of service" settings
for this channel.
|
void |
RabbitMQClient.basicQos(int prefetchSize,
int prefetchCount,
boolean global,
Handler<AsyncResult<Void>> resultHandler)
Request specific "quality of service" settings.
|
void |
RabbitMQConsumer.cancel(Handler<AsyncResult<Void>> cancelResult)
Stop message consumption from a queue.
|
void |
RabbitMQClient.confirmSelect(Handler<AsyncResult<Void>> resultHandler)
Enables publisher acknowledgements on this channel.
|
void |
RabbitMQClient.exchangeBind(String destination,
String source,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Bind an exchange to an exchange.
|
void |
RabbitMQClient.exchangeBind(String destination,
String source,
String routingKey,
Map<String,Object> arguments,
Handler<AsyncResult<Void>> resultHandler)
Bind an exchange to an exchange.
|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
Handler<AsyncResult<Void>> resultHandler)
Declare an exchange.
|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<Void>> resultHandler)
Declare an exchange with additional parameters such as dead lettering, an alternate exchange or TTL.
|
void |
RabbitMQClient.exchangeDeclare(String exchange,
String type,
boolean durable,
boolean autoDelete,
Map<String,String> config,
Handler<AsyncResult<Void>> resultHandler)
Deprecated.
Use
RabbitMQClient.exchangeDeclare(String, String, boolean, boolean, JsonObject, Handler) instead for
support for more than just String config values |
void |
RabbitMQClient.exchangeDelete(String exchange,
Handler<AsyncResult<Void>> resultHandler)
Delete an exchange, without regard for whether it is in use or not.
|
void |
RabbitMQClient.exchangeUnbind(String destination,
String source,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Unbind an exchange from an exchange.
|
void |
RabbitMQClient.exchangeUnbind(String destination,
String source,
String routingKey,
Map<String,Object> arguments,
Handler<AsyncResult<Void>> resultHandler)
Unbind an exchange from an exchange.
|
void |
RabbitMQClient.messageCount(String queue,
Handler<AsyncResult<Long>> resultHandler)
Returns the number of messages in a queue ready to be delivered.
|
void |
RabbitMQClient.queueBind(String queue,
String exchange,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Bind a queue to an exchange
|
void |
RabbitMQClient.queueBind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments,
Handler<AsyncResult<Void>> resultHandler)
Bind a queue to an exchange
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Handler<AsyncResult<JsonObject>> resultHandler)
Declare a queue
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
JsonObject config,
Handler<AsyncResult<JsonObject>> resultHandler)
Declare a queue with config options
|
void |
RabbitMQClient.queueDeclare(String queue,
boolean durable,
boolean exclusive,
boolean autoDelete,
Map<String,String> config,
Handler<AsyncResult<JsonObject>> resultHandler)
Deprecated.
See
RabbitMQClient.queueDeclare(String, boolean, boolean, boolean, JsonObject, Handler) instead for
support for more than just String config values |
void |
RabbitMQClient.queueDeclareAuto(Handler<AsyncResult<JsonObject>> resultHandler)
Actively declare a server-named exclusive, autodelete, non-durable queue.
|
void |
RabbitMQClient.queueDelete(String queue,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue, without regard for whether it is in use or has messages on it
|
void |
RabbitMQClient.queueDeleteIf(String queue,
boolean ifUnused,
boolean ifEmpty,
Handler<AsyncResult<JsonObject>> resultHandler)
Delete a queue
|
void |
RabbitMQClient.queueUnbind(String queue,
String exchange,
String routingKey,
Handler<AsyncResult<Void>> resultHandler)
Unbind a queue from an exchange
|
void |
RabbitMQClient.queueUnbind(String queue,
String exchange,
String routingKey,
Map<String,Object> arguments,
Handler<AsyncResult<Void>> resultHandler)
Unbind a queue from an exchange
|
void |
RabbitMQClient.start(Handler<AsyncResult<Void>> resultHandler)
Start the rabbitMQ client.
|
void |
RabbitMQClient.stop(Handler<AsyncResult<Void>> resultHandler)
Stop the rabbitMQ client.
|
void |
RabbitMQClient.waitForConfirms(Handler<AsyncResult<Void>> resultHandler)
Wait until all messages published since the last call have been either ack'd or nack'd by the broker.
|
void |
RabbitMQClient.waitForConfirms(long timeout,
Handler<AsyncResult<Void>> resultHandler)
Wait until all messages published since the last call have been either ack'd or nack'd by the broker; or until timeout elapses.
|
| Modifier and Type | Method and Description |
|---|---|
AmqpConnection |
AmqpConnection.close(Handler<AsyncResult<Void>> done)
Closes the AMQP connection, i.e.
|
void |
AmqpSender.close(Handler<AsyncResult<Void>> handler)
Closes the sender.
|
void |
AmqpReceiver.close(Handler<AsyncResult<Void>> handler)
Closes the receiver.
|
void |
AmqpClient.close(Handler<AsyncResult<Void>> closeHandler)
Closes the client.
|
AmqpClient |
AmqpClient.connect(Handler<AsyncResult<AmqpConnection>> connectionHandler)
Connects to the AMQP broker or router.
|
AmqpConnection |
AmqpConnection.createAnonymousSender(Handler<AsyncResult<AmqpSender>> completionHandler)
Creates an anonymous sender.
|
AmqpConnection |
AmqpConnection.createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a dynamic receiver.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpClient |
AmqpClient.createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpClient |
AmqpClient.createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpConnection |
AmqpConnection.createSender(String address,
AmqpSenderOptions options,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpClient |
AmqpClient.createSender(String address,
AmqpSenderOptions options,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpConnection |
AmqpConnection.createSender(String address,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpClient |
AmqpClient.createSender(String address,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
void |
AmqpSender.end(AmqpMessage data,
Handler<AsyncResult<Void>> handler)
Same as but with an
handler called when the operation completes |
void |
AmqpSender.end(Handler<AsyncResult<Void>> handler)
Same as
WriteStream.end() but with an handler called when the operation completes |
void |
AmqpReceiver.pipeTo(WriteStream<AmqpMessage> dst,
Handler<AsyncResult<Void>> handler)
Pipe this
ReadStream to the WriteStream. |
AmqpSender |
AmqpSender.sendWithAck(AmqpMessage message,
Handler<AsyncResult<Void>> acknowledgementHandler)
Sends an AMQP message and waits for an acknowledgement.
|
AmqpSender |
AmqpSender.write(AmqpMessage data,
Handler<AsyncResult<Void>> handler) |
| Modifier and Type | Method and Description |
|---|---|
void |
AmqpBridge.close(Handler<AsyncResult<Void>> resultHandler)
Shuts the bridge down, closing the underlying connection.
|
void |
AmqpBridge.start(String hostname,
int port,
Handler<AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
void |
AmqpBridge.start(String hostname,
int port,
String username,
String password,
Handler<AsyncResult<AmqpBridge>> resultHandler)
Starts the bridge, establishing the underlying connection.
|
| Modifier and Type | Method and Description |
|---|---|
ResultSet |
ResultSet.all(Handler<AsyncResult<List<com.datastax.driver.core.Row>>> handler)
The method should not be used concurrently with others like ResultSet.several(int, io.vertx.core.Handler<io.vertx.core.AsyncResult<java.util.List<com.datastax.driver.core.Row>>>) or ResultSet.one(io.vertx.core.Handler<io.vertx.core.AsyncResult<com.datastax.driver.core.Row>>) |