| Modifier and Type | Method and Description |
|---|---|
AmqpMessage |
AmqpMessage.accepted()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message.
|
AmqpConnection |
AmqpConnection.close(Handler<AsyncResult<Void>> done)
Closes the AMQP connection, i.e.
|
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.
|
AmqpConnection |
AmqpConnection.exceptionHandler(Handler<Throwable> handler)
Registers a handler called on disconnection.
|
AmqpMessage |
AmqpMessage.modified(boolean deliveryFailed,
boolean undeliverableHere)
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message as
modified. |
AmqpMessage |
AmqpMessage.rejected()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message as
rejected. |
AmqpMessage |
AmqpMessage.released()
When receiving a message, and when auto-acknowledgement is disabled, this method is used to acknowledge
the incoming message as
released. |
AmqpSender |
AmqpSender.send(AmqpMessage message)
Sends an AMQP message.
|
AmqpSender |
AmqpSender.sendWithAck(AmqpMessage message,
Handler<AsyncResult<Void>> acknowledgementHandler)
Sends an AMQP message and waits for an acknowledgement.
|
| Modifier and Type | Method and Description |
|---|---|
CircuitBreaker |
CircuitBreaker.close()
Closes the circuit breaker.
|
CircuitBreaker |
CircuitBreaker.closeHandler(Handler<Void> handler)
Sets a
Handler invoked when the circuit breaker state switches to close. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReport(Promise<T> resultPromise,
Handler<Promise<T>> command)
Same as
CircuitBreaker.executeAndReportWithFallback(Promise, Handler, Function) but using the circuit breaker default
fallback. |
<T> CircuitBreaker |
CircuitBreaker.executeAndReportWithFallback(Promise<T> resultPromise,
Handler<Promise<T>> command,
Function<Throwable,T> fallback)
Executes the given operation with the circuit breaker control.
|
<T> CircuitBreaker |
CircuitBreaker.fallback(Function<Throwable,T> handler)
Sets a default
Function invoked when the bridge is open to handle the "request", or on failure
if CircuitBreakerOptions.isFallbackOnFailure() is enabled. |
CircuitBreaker |
CircuitBreaker.halfOpenHandler(Handler<Void> handler)
Sets a
Handler invoked when the circuit breaker state switches to half-open. |
CircuitBreaker |
CircuitBreaker.open()
Explicitly opens the circuit.
|
CircuitBreaker |
CircuitBreaker.openHandler(Handler<Void> handler)
Sets a
Handler invoked when the circuit breaker state switches to open. |
CircuitBreaker |
CircuitBreaker.reset()
Resets the circuit breaker state (number of failure set to 0 and state set to closed).
|
CircuitBreaker |
CircuitBreaker.retryPolicy(Function<Integer,Long> retryPolicy) |
| Modifier and Type | Method and Description |
|---|---|
ConfigRetriever |
ConfigRetriever.setBeforeScanHandler(Handler<Void> handler)
Registers a handler called before every scan.
|
ConfigRetriever |
ConfigRetriever.setConfigurationProcessor(Function<JsonObject,JsonObject> processor)
Registers a handler that process the configuration before being injected into
ConfigRetriever.getConfig(Handler) or ConfigRetriever.listen(Handler). |
| Modifier and Type | Method and Description |
|---|---|
MultiMap |
MultiMap.add(CharSequence name,
CharSequence value)
Like
MultiMap.add(String, String) but accepting CharSequence as parameters |
MultiMap |
MultiMap.add(CharSequence name,
Iterable<CharSequence> values)
Like
MultiMap.add(String, Iterable) but accepting CharSequence as parameters |
MultiMap |
MultiMap.add(String name,
Iterable<String> values)
Adds a new values under the specified name
|
MultiMap |
MultiMap.add(String name,
String value)
Adds a new value with the specified name and value.
|
MultiMap |
MultiMap.addAll(Map<String,String> headers)
Adds all the entries from a Map to this
|
MultiMap |
MultiMap.addAll(MultiMap map)
Adds all the entries from another MultiMap to this one
|
MultiMap |
MultiMap.clear()
Removes all
|
Vertx |
Vertx.exceptionHandler(Handler<Throwable> handler)
Set a default exception handler for
Context, set on Context.exceptionHandler(Handler) at creation. |
Context |
Context.exceptionHandler(Handler<Throwable> handler)
Set an exception handler called when the context runs an action throwing an uncaught throwable.
When this handler is called,
Vertx.currentContext() will return this context. |
Future<T> |
Future.onComplete(Handler<AsyncResult<T>> handler)
Add a handler to be notified of the result.
|
default Future<T> |
Future.onFailure(Handler<Throwable> handler)
Add a handler to be notified of the failed result.
|
default Future<T> |
Future.onSuccess(Handler<T> handler)
Add a handler to be notified of the succeeded result.
|
MultiMap |
MultiMap.remove(CharSequence name)
Like
MultiMap.remove(String) but accepting CharSequence as parameters |
MultiMap |
MultiMap.remove(String name)
Removes the value with the given name
|
MultiMap |
MultiMap.set(CharSequence name,
CharSequence value)
Like
MultiMap.set(String, String) but accepting CharSequence as parameters |
MultiMap |
MultiMap.set(CharSequence name,
Iterable<CharSequence> values)
Like
MultiMap.set(String, Iterable) but accepting CharSequence as parameters |
MultiMap |
MultiMap.set(String name,
Iterable<String> values)
Sets values for the specified name.
|
MultiMap |
MultiMap.set(String name,
String value)
Sets a
value under the specified name. |
MultiMap |
MultiMap.setAll(Map<String,String> headers)
Cleans and set all values of the given instance
|
MultiMap |
MultiMap.setAll(MultiMap map)
Cleans this instance.
|
| Modifier and Type | Method and Description |
|---|---|
Buffer |
Buffer.appendBuffer(Buffer buff)
Appends the specified
Buffer to the end of this Buffer. |
Buffer |
Buffer.appendBuffer(Buffer buff,
int offset,
int len)
Appends the specified
Buffer starting at the offset using len to the end of this Buffer. |
Buffer |
Buffer.appendByte(byte b)
Appends the specified
byte to the end of the Buffer. |
Buffer |
Buffer.appendBytes(byte[] bytes)
Appends the specified
byte[] to the end of the Buffer. |
Buffer |
Buffer.appendBytes(byte[] bytes,
int offset,
int len)
Appends the specified number of bytes from
byte[] to the end of the Buffer, starting at the given offset. |
Buffer |
Buffer.appendDouble(double d)
Appends the specified
double to the end of the Buffer. |
Buffer |
Buffer.appendFloat(float f)
Appends the specified
float to the end of the Buffer. |
Buffer |
Buffer.appendInt(int i)
Appends the specified
int to the end of the Buffer. |
Buffer |
Buffer.appendIntLE(int i)
Appends the specified
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendLong(long l)
Appends the specified
long to the end of the Buffer. |
Buffer |
Buffer.appendLongLE(long l)
Appends the specified
long to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendMedium(int i)
Appends the specified 24bit
int to the end of the Buffer. |
Buffer |
Buffer.appendMediumLE(int i)
Appends the specified 24bit
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendShort(short s)
Appends the specified
short to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendShortLE(short s)
Appends the specified
short to the end of the Buffer in the Little Endian Byte Order.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendString(String str)
Appends the specified
String str to the end of the Buffer with UTF-8 encoding. |
Buffer |
Buffer.appendString(String str,
String enc)
Appends the specified
String to the end of the Buffer with the encoding as specified by enc. |
Buffer |
Buffer.appendUnsignedByte(short b)
Appends the specified unsigned
byte to the end of the Buffer. |
Buffer |
Buffer.appendUnsignedInt(long i)
Appends the specified unsigned
int to the end of the Buffer. |
Buffer |
Buffer.appendUnsignedIntLE(long i)
Appends the specified unsigned
int to the end of the Buffer in the Little Endian Byte Order. |
Buffer |
Buffer.appendUnsignedShort(int s)
Appends the specified unsigned
short to the end of the Buffer.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.appendUnsignedShortLE(int s)
Appends the specified unsigned
short to the end of the Buffer in the Little Endian Byte Order.The buffer will expand as necessary to accommodate any bytes written. |
Buffer |
Buffer.getBytes(byte[] dst)
Transfers the content of the Buffer into a
byte[]. |
Buffer |
Buffer.getBytes(byte[] dst,
int dstIndex)
Transfers the content of the Buffer into a
byte[] at the specific destination. |
Buffer |
Buffer.getBytes(int start,
int end,
byte[] dst)
Transfers the content of the Buffer starting at position
start and ending at position end - 1
into a byte[]. |
Buffer |
Buffer.getBytes(int start,
int end,
byte[] dst,
int dstIndex)
Transfers the content of the Buffer starting at position
start and ending at position end - 1
into a byte[] at the specific destination. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b. |
Buffer |
Buffer.setBuffer(int pos,
Buffer b,
int offset,
int len)
Sets the bytes at position
pos in the Buffer to the bytes represented by the Buffer b on the given offset and len. |
Buffer |
Buffer.setByte(int pos,
byte b)
Sets the
byte at position pos in the Buffer to the value b. |
Buffer |
Buffer.setBytes(int pos,
byte[] b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the byte[] b. |
Buffer |
Buffer.setBytes(int pos,
byte[] b,
int offset,
int len)
Sets the given number of bytes at position
pos in the Buffer to the bytes represented by the byte[] b. |
Buffer |
Buffer.setBytes(int pos,
ByteBuffer b)
Sets the bytes at position
pos in the Buffer to the bytes represented by the ByteBuffer b. |
Buffer |
Buffer.setDouble(int pos,
double d)
Sets the
double at position pos in the Buffer to the value d. |
Buffer |
Buffer.setFloat(int pos,
float f)
Sets the
float at position pos in the Buffer to the value f. |
Buffer |
Buffer.setInt(int pos,
int i)
Sets the
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setIntLE(int pos,
int i)
Sets the
int at position pos in the Buffer to the value i in the Little Endian Byte Order. |
Buffer |
Buffer.setLong(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l. |
Buffer |
Buffer.setLongLE(int pos,
long l)
Sets the
long at position pos in the Buffer to the value l in the Little Endian Byte Order. |
Buffer |
Buffer.setMedium(int pos,
int i)
Sets the 24bit
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setMediumLE(int pos,
int i)
Sets the 24bit
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setShort(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s. |
Buffer |
Buffer.setShortLE(int pos,
short s)
Sets the
short at position pos in the Buffer to the value s in the Little Endian Byte Order. |
Buffer |
Buffer.setString(int pos,
String str)
Sets the bytes at position
pos in the Buffer to the value of str encoded in UTF-8. |
Buffer |
Buffer.setString(int pos,
String str,
String enc)
Sets the bytes at position
pos in the Buffer to the value of str encoded in encoding enc. |
Buffer |
Buffer.setUnsignedByte(int pos,
short b)
Sets the unsigned
byte at position pos in the Buffer to the value b. |
Buffer |
Buffer.setUnsignedInt(int pos,
long i)
Sets the unsigned
int at position pos in the Buffer to the value i. |
Buffer |
Buffer.setUnsignedIntLE(int pos,
long i)
Sets the unsigned
int at position pos in the Buffer to the value i in the Little Endian Byte Order. |
Buffer |
Buffer.setUnsignedShort(int pos,
int s)
Sets the unsigned
short at position pos in the Buffer to the value s. |
Buffer |
Buffer.setUnsignedShortLE(int pos,
int s)
Sets the unsigned
short at position pos in the Buffer to the value s in the Little Endian Byte Order. |
| Modifier and Type | Method and Description |
|---|---|
CLI |
CLI.addArgument(Argument arg)
Adds an argument.
|
CLI |
CLI.addArguments(List<Argument> args)
Adds a set of arguments.
|
CLI |
CLI.addOption(Option option)
Adds an option.
|
CLI |
CLI.addOptions(List<Option> options)
Adds a set of options.
|
CLI |
CLI.removeArgument(int index)
Removes an argument identified by its index.
|
CLI |
CLI.removeOption(String name)
Removes an option identified by its name.
|
CLI |
CLI.setArguments(List<Argument> args)
Sets the list of arguments.
|
CLI |
CLI.setDescription(String desc) |
CLI |
CLI.setHidden(boolean hidden)
Sets whether or not the current instance of
CLI must be hidden. |
CLI |
CLI.setName(String name)
Sets the name of the CLI.
|
CLI |
CLI.setOptions(List<Option> options)
Sets the list of arguments.
|
CLI |
CLI.setPriority(int priority)
Sets the priority of the CLI.
|
CLI |
CLI.setSummary(String summary)
Sets the summary of the CLI.
|
| Modifier and Type | Method and Description |
|---|---|
DatagramSocket |
DatagramSocket.blockMulticastGroup(String multicastAddress,
String sourceToBlock,
Handler<AsyncResult<Void>> 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<Void>> handler)
Block the given address for the given multicast address on the given network interface and notifies
the
Handler once the operation completes. |
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<Void>> handler)
Joins a multicast group and listens for packets send to it.
|
DatagramSocket |
DatagramSocket.listenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<Void>> 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<Void>> handler)
Write the given
Buffer to the SocketAddress. |
DatagramSocket |
DatagramSocket.send(String str,
int port,
String host,
Handler<AsyncResult<Void>> handler)
Write the given
String to the SocketAddress using UTF8 encoding. |
DatagramSocket |
DatagramSocket.send(String str,
String enc,
int port,
String host,
Handler<AsyncResult<Void>> handler)
Write the given
String to the SocketAddress using the given encoding. |
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
Handler<AsyncResult<Void>> handler)
Leaves a multicast group and stops listening for packets send to it.
|
DatagramSocket |
DatagramSocket.unlistenMulticastGroup(String multicastAddress,
String networkInterface,
String source,
Handler<AsyncResult<Void>> 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 |
|---|---|
<T> EventBus |
EventBus.addInboundInterceptor(Handler<DeliveryContext<T>> interceptor)
Add an interceptor that will be called whenever a message is received by Vert.x
|
<T> EventBus |
EventBus.addOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)
Add an interceptor that will be called whenever a message is sent from Vert.x
|
MessageProducer<T> |
MessageProducer.deliveryOptions(DeliveryOptions options)
Update the delivery options of this producer.
|
EventBus |
EventBus.publish(String address,
Object message)
Publish a message.
|
EventBus |
EventBus.publish(String address,
Object message,
DeliveryOptions options)
Like
EventBus.publish(String, Object) but specifying options that can be used to configure the delivery. |
<T> EventBus |
EventBus.removeInboundInterceptor(Handler<DeliveryContext<T>> interceptor)
Remove an interceptor that was added by
EventBus.addInboundInterceptor(Handler) |
<T> EventBus |
EventBus.removeOutboundInterceptor(Handler<DeliveryContext<T>> interceptor)
Remove an interceptor that was added by
EventBus.addOutboundInterceptor(Handler) |
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. |
EventBus |
EventBus.send(String address,
Object message)
Sends a message.
|
EventBus |
EventBus.send(String address,
Object message,
DeliveryOptions options)
Like
EventBus.send(String, Object) but specifying options that can be used to configure the delivery. |
| 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.chmodBlocking(String path,
String perms)
Blocking version of
FileSystem.chmod(String, String, Handler) |
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.chmodRecursiveBlocking(String path,
String perms,
String dirPerms)
Blocking version of
FileSystem.chmodRecursive(String, String, String, Handler) |
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. |
FileSystem |
FileSystem.chownBlocking(String path,
String user,
String group)
Blocking version of
FileSystem.chown(String, String, String, Handler) |
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.copyBlocking(String from,
String to)
Blocking version of
FileSystem.copy(String, String, Handler) |
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.copyRecursiveBlocking(String from,
String to,
boolean recursive)
Blocking version of
FileSystem.copyRecursive(String, String, boolean, Handler) |
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.createFileBlocking(String path)
Blocking version of
FileSystem.createFile(String, Handler) |
FileSystem |
FileSystem.createFileBlocking(String path,
String perms)
Blocking version of
FileSystem.createFile(String, String, Handler) |
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.deleteBlocking(String path)
Blocking version of
FileSystem.delete(String, Handler) |
FileSystem |
FileSystem.deleteRecursive(String path,
boolean recursive,
Handler<AsyncResult<Void>> handler)
Deletes the file represented by the specified
path, asynchronously. |
FileSystem |
FileSystem.deleteRecursiveBlocking(String path,
boolean recursive)
Blocking version of
FileSystem.deleteRecursive(String, boolean, 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.linkBlocking(String link,
String existing)
Blocking version of
FileSystem.link(String, String, Handler) |
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.mkdirBlocking(String path)
Blocking version of
FileSystem.mkdir(String, Handler) |
FileSystem |
FileSystem.mkdirBlocking(String path,
String perms)
Blocking version of
FileSystem.mkdir(String, String, Handler) |
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.mkdirsBlocking(String path)
Blocking version of
FileSystem.mkdirs(String, Handler) |
FileSystem |
FileSystem.mkdirsBlocking(String path,
String perms)
Blocking version of
FileSystem.mkdirs(String, String, Handler) |
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.moveBlocking(String from,
String to)
Blocking version of
FileSystem.move(String, String, Handler) |
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. |
AsyncFile |
AsyncFile.setReadBufferSize(int readBufferSize)
Sets the buffer size that will be used to read the data from the file.
|
AsyncFile |
AsyncFile.setReadLength(long readLength)
Sets the number of bytes that will be read when using the file as a
ReadStream. |
AsyncFile |
AsyncFile.setReadPos(long readPos)
Sets the position from which data will be read from when using the file as a
ReadStream. |
AsyncFile |
AsyncFile.setWritePos(long writePos)
Sets the position from which data will be written when using the file as a
WriteStream. |
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.symlinkBlocking(String link,
String existing)
Blocking version of
FileSystem.link(String, String, Handler) |
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.truncateBlocking(String path,
long len)
Blocking version of
FileSystem.truncate(String, long, Handler) |
FileSystem |
FileSystem.unlink(String link,
Handler<AsyncResult<Void>> handler)
Unlinks the link on the file system represented by the path
link, asynchronously. |
FileSystem |
FileSystem.unlinkBlocking(String link)
Blocking version of
FileSystem.unlink(String, Handler) |
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. |
FileSystem |
FileSystem.writeFileBlocking(String path,
Buffer data)
Blocking version of
FileSystem.writeFile(String, Buffer, Handler) |
| Modifier and Type | Method and Description |
|---|---|
HttpServerResponse |
HttpServerResponse.addCookie(Cookie cookie)
Add a cookie.
|
WebSocketBase |
WebSocketBase.binaryMessageHandler(Handler<Buffer> handler)
Set a binary message handler on the connection.
|
default HttpClientResponse |
HttpClientResponse.body(Handler<AsyncResult<Buffer>> handler)
Same as
HttpClientResponse.body() but with an handler called when the operation completes |
HttpServerResponse |
HttpServerResponse.bodyEndHandler(Handler<Void> handler)
Provides a handler that will be called after the last part of the body is written to the wire.
|
default HttpServerRequest |
HttpServerRequest.bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.
|
default HttpClientResponse |
HttpClientResponse.bodyHandler(Handler<Buffer> bodyHandler)
Convenience method for receiving the entire request body in one piece.
|
WebSocketBase |
WebSocketBase.closeHandler(Handler<Void> handler)
Set a close handler.
|
HttpConnection |
HttpConnection.closeHandler(Handler<Void> handler)
Set a close handler.
|
HttpServerResponse |
HttpServerResponse.closeHandler(Handler<Void> handler)
Set a close handler for the response, this is called when the underlying connection is closed and the response
was still using the connection.
|
HttpServer |
HttpServer.connectionHandler(Handler<HttpConnection> handler)
Set a connection handler for the server.
|
HttpClient |
HttpClient.connectionHandler(Handler<HttpConnection> handler)
Set a connection handler for the client.
|
HttpClientRequest |
HttpClientRequest.continueHandler(Handler<Void> handler)
If you send an HTTP request with the header
Expect set to the value 100-continue
and the server responds with an interim HTTP response with a status code of 100 and a continue handler
has been set using this method, then the handler will be called. |
HttpServerRequest |
HttpServerRequest.customFrameHandler(Handler<HttpFrame> handler)
Set a custom frame handler.
|
HttpClientResponse |
HttpClientResponse.customFrameHandler(Handler<HttpFrame> handler)
Set an custom frame handler.
|
HttpServerResponse |
HttpServerResponse.endHandler(Handler<Void> handler)
Set an end handler for the response.
|
HttpServer |
HttpServer.exceptionHandler(Handler<Throwable> handler)
Set an exception handler called for socket errors happening before the HTTP connection
is established, e.g during the TLS handshake.
|
HttpConnection |
HttpConnection.exceptionHandler(Handler<Throwable> handler)
Set an handler called when a connection error happens
|
WebSocketBase |
WebSocketBase.frameHandler(Handler<WebSocketFrame> handler)
Set a frame handler on the connection.
|
default HttpConnection |
HttpConnection.goAway(long errorCode)
Like
HttpConnection.goAway(long, int) with a last stream id -1 which means to disallow any new stream creation. |
default HttpConnection |
HttpConnection.goAway(long errorCode,
int lastStreamId)
Like
HttpConnection.goAway(long, int, Buffer) with no buffer. |
HttpConnection |
HttpConnection.goAway(long errorCode,
int lastStreamId,
Buffer debugData)
Send a go away frame to the remote endpoint of the connection.
|
HttpConnection |
HttpConnection.goAwayHandler(Handler<GoAway> handler)
Set an handler called when a GOAWAY frame is received.
|
HttpServerResponse |
HttpServerResponse.headersEndHandler(Handler<Void> handler)
Provide a handler that will be called just before the headers are written to the wire.
|
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.
|
HttpConnection |
HttpConnection.pingHandler(Handler<Buffer> handler)
Set an handler notified when a PING frame is received from the remote endpoint.
|
WebSocketBase |
WebSocketBase.pongHandler(Handler<Buffer> handler)
Set a pong frame handler on the connection.
|
default 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. |
default 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. |
default HttpServerResponse |
HttpServerResponse.push(HttpMethod method,
String host,
String path,
Handler<AsyncResult<HttpServerResponse>> handler)
Like
HttpServerResponse.push(HttpMethod, String, String, MultiMap, Handler) with no headers. |
default 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. |
HttpClientRequest |
HttpClientRequest.pushHandler(Handler<HttpClientRequest> handler)
Set a push handler for this request.
The handler is called when the client receives a push promise from the server.
|
HttpServerResponse |
HttpServerResponse.putHeader(CharSequence name,
CharSequence value)
Like
HttpServerResponse.putHeader(String, String) but using CharSequence |
HttpClientRequest |
HttpClientRequest.putHeader(CharSequence name,
CharSequence value)
Like
HttpClientRequest.putHeader(String, String) but using CharSequence |
HttpServerResponse |
HttpServerResponse.putHeader(CharSequence name,
Iterable<CharSequence> values)
Like
HttpServerResponse.putHeader(String, Iterable) but with CharSequence Iterable |
HttpClientRequest |
HttpClientRequest.putHeader(CharSequence name,
Iterable<CharSequence> values)
Like
HttpClientRequest.putHeader(String, Iterable) but using CharSequence |
HttpServerResponse |
HttpServerResponse.putHeader(String name,
Iterable<String> values)
Like
HttpServerResponse.putHeader(String, String) but providing multiple values via a String Iterable |
HttpClientRequest |
HttpClientRequest.putHeader(String name,
Iterable<String> values)
Put an HTTP header with multiple values
|
HttpServerResponse |
HttpServerResponse.putHeader(String name,
String value)
Put an HTTP header
|
HttpClientRequest |
HttpClientRequest.putHeader(String name,
String value)
Put an HTTP header
|
HttpServerResponse |
HttpServerResponse.putTrailer(CharSequence name,
CharSequence value)
Like
HttpServerResponse.putTrailer(String, String) but using CharSequence |
HttpServerResponse |
HttpServerResponse.putTrailer(CharSequence name,
Iterable<CharSequence> value)
Like
HttpServerResponse.putTrailer(String, Iterable) but with CharSequence Iterable |
HttpServerResponse |
HttpServerResponse.putTrailer(String name,
Iterable<String> values)
Like
HttpServerResponse.putTrailer(String, String) but providing multiple values via a String Iterable |
HttpServerResponse |
HttpServerResponse.putTrailer(String name,
String value)
Put an HTTP trailer
|
HttpClient |
HttpClient.redirectHandler(Function<HttpClientResponse,Future<RequestOptions>> handler)
Set a redirect handler for the http client.
|
HttpConnection |
HttpConnection.remoteSettingsHandler(Handler<Http2Settings> handler)
Set an handler that is called when remote endpoint
Http2Settings are updated. |
HttpServer |
HttpServer.requestHandler(Handler<HttpServerRequest> handler)
Set the request handler for the server to
requestHandler. |
HttpClientRequest |
HttpClientRequest.response(Handler<AsyncResult<HttpClientResponse>> handler)
Set a callback for the associated
HttpClientResponse. |
default HttpServerRequest |
HttpServerRequest.routed(String route)
Marks this request as being routed to the given route.
|
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. |
HttpClientRequest |
HttpClientRequest.sendHead(Handler<AsyncResult<Void>> completionHandler)
Like
HttpClientRequest.sendHead() but with an handler after headers have been sent. |
HttpServerResponse |
HttpServerResponse.setChunked(boolean chunked)
If
chunked is true, this response will use HTTP chunked encoding, and each call to write to the body
will correspond to a new HTTP chunk sent on the wire. |
HttpClientRequest |
HttpClientRequest.setChunked(boolean chunked)
If chunked is true then the request will be set into HTTP chunked mode
|
Cookie |
Cookie.setDomain(String domain)
Sets the domain of this cookie
|
HttpServerRequest |
HttpServerRequest.setExpectMultipart(boolean expect)
Call this with true if you are expecting a multi-part body to be submitted in the request.
|
HttpClientRequest |
HttpClientRequest.setFollowRedirects(boolean followRedirects)
Set the request to follow HTTP redirects up to
HttpClientOptions.getMaxRedirects(). |
HttpClientRequest |
HttpClientRequest.setHost(String host)
Set the host value of the HTTP/1.1
host header or HTTP/2 authority pseudo header |
Cookie |
Cookie.setHttpOnly(boolean httpOnly)
Determines if this cookie is HTTP only.
|
Cookie |
Cookie.setMaxAge(long maxAge)
Sets the maximum age of this cookie in seconds.
|
HttpClientRequest |
HttpClientRequest.setMaxRedirects(int maxRedirects)
Set the max number of HTTP redirects this request will follow.
|
HttpClientRequest |
HttpClientRequest.setMethod(HttpMethod method)
Set the HTTP method for this request.
|
Cookie |
Cookie.setPath(String path)
Sets the path of this cookie.
|
HttpClientRequest |
HttpClientRequest.setPort(int port)
Set the port value of the HTTP/1.1
host header or HTTP/2 authority pseudo header |
Cookie |
Cookie.setSameSite(CookieSameSite policy)
Sets the same site of this cookie.
|
Cookie |
Cookie.setSecure(boolean secure)
Sets the security getStatus of this cookie
|
HttpServerResponse |
HttpServerResponse.setStatusCode(int statusCode)
Set the status code.
|
HttpServerResponse |
HttpServerResponse.setStatusMessage(String statusMessage)
Set the status message
|
default HttpServerResponse |
HttpServerResponse.setStreamPriority(StreamPriority streamPriority)
Sets the priority of the associated stream
This is not implemented for HTTP/1.x.
|
default HttpClientRequest |
HttpClientRequest.setStreamPriority(StreamPriority streamPriority)
Sets the priority of the associated stream.
|
HttpClientRequest |
HttpClientRequest.setTimeout(long timeoutMs)
Set's the amount of time after which if the request does not return any data within the timeout period an
TimeoutException will be passed to the exception handler (if provided) and
the request will be closed. |
HttpClientRequest |
HttpClientRequest.setURI(String uri)
Set the request uri.
|
Cookie |
Cookie.setValue(String value)
Sets the value of this cookie
|
default HttpConnection |
HttpConnection.setWindowSize(int windowSize)
Update the current connection wide window size to a new size.
|
HttpConnection |
HttpConnection.shutdownHandler(Handler<Void> handler)
Set an handler called when a GOAWAY frame has been sent or received and all connections are closed.
|
HttpServerRequest |
HttpServerRequest.streamPriorityHandler(Handler<StreamPriority> handler)
Set an handler for stream priority changes
|
HttpClientResponse |
HttpClientResponse.streamPriorityHandler(Handler<StreamPriority> handler)
Set an handler for stream priority changes.
|
WebSocketBase |
WebSocketBase.textMessageHandler(Handler<String> handler)
Set a text message handler on the connection.
|
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. |
HttpServerRequest |
HttpServerRequest.uploadHandler(Handler<HttpServerFileUpload> uploadHandler)
Set an upload handler.
|
HttpServer |
HttpServer.webSocketHandler(Handler<ServerWebSocket> handler)
Set the WebSocket handler for the server to
wsHandler. |
WebSocketBase |
WebSocketBase.writeBinaryMessage(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeBinaryMessage(Buffer) but with an handler called when the operation completes |
HttpServerResponse |
HttpServerResponse.writeContinue()
Used to write an interim 100 Continue response to signify that the client should send the rest of the request.
|
default HttpServerResponse |
HttpServerResponse.writeCustomFrame(HttpFrame frame)
Like
HttpServerResponse.writeCustomFrame(int, int, Buffer) but with an HttpFrame. |
default HttpClientRequest |
HttpClientRequest.writeCustomFrame(HttpFrame frame)
Like
HttpClientRequest.writeCustomFrame(int, int, Buffer) but with an HttpFrame. |
HttpServerResponse |
HttpServerResponse.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the response, allowing to extend the HTTP/2 protocol.
|
HttpClientRequest |
HttpClientRequest.writeCustomFrame(int type,
int flags,
Buffer payload)
Write an HTTP/2 frame to the request, allowing to extend the HTTP/2 protocol.
|
WebSocketBase |
WebSocketBase.writeFinalBinaryFrame(Buffer data,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFinalBinaryFrame(Buffer, Handler) but with an handler called when the operation completes |
WebSocketBase |
WebSocketBase.writeFinalTextFrame(String text,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFinalTextFrame(String, Handler) but with an handler called when the operation completes |
WebSocketBase |
WebSocketBase.writeFrame(WebSocketFrame frame,
Handler<AsyncResult<Void>> handler)
Same as
WebSocketBase.writeFrame(WebSocketFrame) but with an handler called when the operation completes |
WebSocketBase |
WebSocketBase.writePing(Buffer data,
Handler<AsyncResult<Void>> handler)
Writes a ping frame to the connection.
|
WebSocketBase |
WebSocketBase.writePong(Buffer data,
Handler<AsyncResult<Void>> handler)
Writes a pong frame to the connection.
|
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 |
|---|---|
JsonPointer |
JsonPointer.append(int index)
Append the
index as reference token to JsonPointer |
JsonPointer |
JsonPointer.append(JsonPointer pointer)
Append all tokens of
pointer to this pointer Note: The base URI of this pointer will remain untouched |
JsonPointer |
JsonPointer.append(List<String> tokens)
Append an unescaped list of
tokens to JsonPointer Note: If you provide escaped paths the behaviour is undefined |
JsonPointer |
JsonPointer.append(String token)
Append an unescaped
token to this pointer Note: If you provide escaped path the behaviour is undefined |
JsonPointer |
JsonPointer.parent()
Remove last reference token of this pointer
|
| Modifier and Type | Method and Description |
|---|---|
NetSocket |
NetSocket.closeHandler(Handler<Void> handler)
Set a handler that will be called when the NetSocket is closed
|
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. |
NetServer |
NetServer.exceptionHandler(Handler<Throwable> handler)
Set an exception handler called for socket errors happening before the connection
is passed to the
NetServer.connectHandler(io.vertx.core.Handler<io.vertx.core.net.NetSocket>), e.g during the TLS handshake. |
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.upgradeToSsl(Handler<AsyncResult<Void>> handler)
Upgrade channel to use SSL/TLS.
|
NetSocket |
NetSocket.upgradeToSsl(String serverName,
Handler<AsyncResult<Void>> handler)
Upgrade channel to use SSL/TLS.
|
| Modifier and Type | Method and Description |
|---|---|
JsonParser |
JsonParser.arrayEventMode()
Flip the parser to emit a stream of events for each new json array.
|
JsonParser |
JsonParser.arrayValueMode()
Flip the parser to emit a single value event for each new json array.
|
JsonParser |
JsonParser.endHandler(Handler<Void> endHandler) |
JsonParser |
JsonParser.exceptionHandler(Handler<Throwable> handler) |
JsonParser |
JsonParser.handler(Handler<JsonEvent> handler) |
RecordParser |
RecordParser.maxRecordSize(int size)
Set the maximum allowed size for a record when using the delimited mode.
|
JsonParser |
JsonParser.objectEventMode()
Flip the parser to emit a stream of events for each new json object.
|
JsonParser |
JsonParser.objectValueMode()
Flip the parser to emit a single value event for each new json object.
|
JsonParser |
JsonParser.write(Buffer buffer)
Handle a
Buffer, pretty much like calling Handler.handle(Object). |
| Modifier and Type | Method and Description |
|---|---|
WriteStream<T> |
WriteStream.drainHandler(Handler<Void> handler)
Set a drain handler on the stream.
|
ReadStream<T> |
ReadStream.endHandler(Handler<Void> endHandler)
Set an end handler.
|
Pipe<T> |
Pipe.endOnComplete(boolean end)
|
Pipe<T> |
Pipe.endOnFailure(boolean end)
|
Pipe<T> |
Pipe.endOnSuccess(boolean end)
|
StreamBase |
StreamBase.exceptionHandler(Handler<Throwable> handler)
Set an exception handler.
|
ReadStream<T> |
ReadStream.fetch(long amount)
Fetch the specified
amount of elements. |
ReadStream<T> |
ReadStream.handler(Handler<T> handler)
Set a data handler.
|
ReadStream<T> |
ReadStream.pause()
Pause the
ReadStream, it sets the buffer in fetch mode and clears the actual demand. |
ReadStream<T> |
ReadStream.resume()
Resume reading, and sets the buffer in
flowing mode. |
Pump |
Pump.setWriteQueueMaxSize(int maxSize)
Set the write queue max size to
maxSize |
WriteStream<T> |
WriteStream.setWriteQueueMaxSize(int maxSize)
Set the maximum size of the write queue to
maxSize. |
Pump |
Pump.start()
Start the Pump.
|
Pump |
Pump.stop()
Stop the Pump.
|
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Modifier and Type | Method and Description |
|---|---|
ChainAuth |
ChainAuth.add(AuthenticationProvider other)
Appends a auth provider to the chain.
|
default User |
User.clearCache()
Deprecated.
This method will be removed. Use
Authorizations.clear() |
String |
KeyStoreOptions.getPassword() |
User |
User.isAuthorized(Authorization authority,
Handler<AsyncResult<Boolean>> resultHandler)
Deprecated.
|
default User |
User.isAuthorized(String authority,
Handler<AsyncResult<Boolean>> resultHandler)
Deprecated.
Use typed alternative
User.isAuthorized(Authorization, Handler) |
HashingStrategy |
HashingStrategy.put(String id,
HashingAlgorithm algorithm)
Put or replace an algorithm into the list of system loaded algorithms.
|
KeyStoreOptions |
KeyStoreOptions.setPassword(String password) |
KeyStoreOptions |
KeyStoreOptions.setPasswordProtection(Map<String,String> passwordProtection) |
KeyStoreOptions |
KeyStoreOptions.setPath(String path) |
KeyStoreOptions |
KeyStoreOptions.setProvider(String provider) |
KeyStoreOptions |
KeyStoreOptions.setType(String type) |
KeyStoreOptions |
KeyStoreOptions.setValue(Buffer value) |
| Modifier and Type | Method and Description |
|---|---|
Authorizations |
Authorizations.add(String providerId,
Authorization authorization) |
Authorizations |
Authorizations.add(String providerId,
Set<Authorization> authorizations) |
Authorizations |
Authorizations.clear() |
Authorizations |
Authorizations.clear(String providerId) |
WildcardPermissionBasedAuthorization |
WildcardPermissionBasedAuthorization.setResource(String resource)
sets an optional resource that the permission is assigned-on
|
RoleBasedAuthorization |
RoleBasedAuthorization.setResource(String resource)
sets an optional resource that the role is assigned-on
|
PermissionBasedAuthorization |
PermissionBasedAuthorization.setResource(String resource)
sets an optional resource that the permission is assigned-on
|
| Modifier and Type | Method and Description |
|---|---|
OAuth2Auth |
OAuth2Auth.decodeToken(String token,
Handler<AsyncResult<AccessToken>> handler)
Deprecated.
|
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.
|
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.
|
OAuth2Auth |
OAuth2Auth.jWKSet(Handler<AsyncResult<Void>> handler)
Retrieve the public server JSON Web Key (JWK) required to verify the authenticity
of issued ID and access tokens.
|
default OAuth2Auth |
OAuth2Auth.loadJWK(Handler<AsyncResult<Void>> handler)
Deprecated.
|
AccessToken |
AccessToken.logout(Handler<AsyncResult<Void>> callback)
Deprecated.
Revoke refresh token and calls the logout endpoint.
|
OAuth2Auth |
OAuth2Auth.missingKeyHandler(Handler<String> handler)
Handled to be called when a key (mentioned on a JWT) is missing from the current config.
|
OAuth2Auth |
OAuth2Auth.rbacHandler(OAuth2RBAC rbac)
Deprecated.
|
AccessToken |
AccessToken.refresh(Handler<AsyncResult<Void>> callback)
Deprecated.
Refresh the access token
|
OAuth2Auth |
OAuth2Auth.refresh(User user,
Handler<AsyncResult<User>> handler)
Refresh the current User (access token).
|
AccessToken |
AccessToken.revoke(String token_type,
Handler<AsyncResult<Void>> callback)
Deprecated.
Revoke access or refresh token
|
default OAuth2Auth |
OAuth2Auth.revoke(User user,
Handler<AsyncResult<Void>> handler)
Revoke an obtained access token.
|
OAuth2Auth |
OAuth2Auth.revoke(User user,
String tokenType,
Handler<AsyncResult<Void>> handler)
Revoke an obtained access or refresh token.
|
AccessToken |
AccessToken.setTrustJWT(boolean trust)
Deprecated.
|
AccessToken |
AccessToken.userInfo(Handler<AsyncResult<JsonObject>> callback)
Deprecated.
Load the user info as per OIDC spec.
|
OAuth2Auth |
OAuth2Auth.userInfo(User user,
Handler<AsyncResult<JsonObject>> handler)
Retrieve profile information and other attributes for a logged-in end-user.
|
| Modifier and Type | Method and Description |
|---|---|
MetaDataService |
MetaDataService.addStatement(JsonObject statement)
Manually feed a Meta Data Statement to the service.
|
WebAuthn |
WebAuthn.authenticatorFetcher(Function<Authenticator,Future<List<Authenticator>>> fetcher)
Provide a
Function that can fetch Authenticators from a backend given the incomplete
Authenticator argument. |
WebAuthn |
WebAuthn.authenticatorUpdater(Function<Authenticator,Future<Void>> updater)
Provide a
Function that can update or insert a Authenticator. |
WebAuthn |
WebAuthn.createCredentialsOptions(JsonObject user,
Handler<AsyncResult<JsonObject>> handler)
Gets a challenge and any other parameters for the
navigator.credentials.create() call. |
default MetaDataService |
MetaDataService.fetchTOC(String url,
Handler<AsyncResult<Boolean>> handler)
Fetches the FIDO2 TOC for the given URL and process the entries to the metadata store.
|
MetaDataService |
MetaDataService.flush()
Clears all loaded statements, both from the TOC and manually inserted.
|
WebAuthn |
WebAuthn.getCredentialsOptions(String name,
Handler<AsyncResult<JsonObject>> handler)
Creates an assertion challenge and any other parameters for the
navigator.credentials.get() call. |
| Modifier and Type | Method and Description |
|---|---|
BaseBridgeEvent |
BaseBridgeEvent.setRawMessage(JsonObject message)
Get the raw JSON message for the event.
|
| Modifier and Type | Method and Description |
|---|---|
HealthChecks |
HealthChecks.invoke(Handler<JsonObject> resultHandler)
Invokes the registered procedures and computes the outcome.
|
HealthChecks |
HealthChecks.invoke(String name,
Handler<AsyncResult<JsonObject>> resultHandler)
Invokes the registered procedure with the given name and sub-procedures.
|
HealthChecks |
HealthChecks.register(String name,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
HealthCheckHandler |
HealthCheckHandler.register(String name,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
HealthCheckHandler |
HealthCheckHandler.register(String name,
long timeout,
Handler<Promise<Status>> procedure)
Registers a health check procedure.
|
HealthChecks |
HealthChecks.unregister(String name)
Unregisters a procedure.
|
HealthCheckHandler |
HealthCheckHandler.unregister(String name)
Unregisters a procedure.
|
| Modifier and Type | Method and Description |
|---|---|
MailAttachment |
MailAttachment.addHeader(String key,
String value)
Add an header to this attachment.
|
MailClient |
MailClient.sendMail(MailMessage email,
Handler<AsyncResult<MailResult>> resultHandler)
send a single mail via MailClient
|
MailAttachment |
MailAttachment.setContentId(String contentId)
set the Content-ID field to be used in the attachment
|
MailAttachment |
MailAttachment.setContentType(String contentType)
set the Content-Type
|
MailAttachment |
MailAttachment.setData(Buffer data)
set the data
|
MailAttachment |
MailAttachment.setDescription(String description)
set the description field to be used in the attachment
|
MailAttachment |
MailAttachment.setDisposition(String disposition)
set the disposition field to be used in the attachment
|
MailAttachment |
MailAttachment.setHeaders(MultiMap headers)
Set the headers to be added for this attachment.
|
MailAttachment |
MailAttachment.setName(String name)
set the name
|
MailAttachment |
MailAttachment.setSize(int size)
Sets the size of the attachment.
|
MailAttachment |
MailAttachment.setStream(ReadStream<Buffer> stream)
Sets the data stream.
|
| Modifier and Type | Method and Description |
|---|---|
MongoClient |
MongoClient.bulkWrite(String collection,
List<BulkOperation> operations,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
Execute a bulk operation.
|
MongoClient |
MongoClient.bulkWriteWithOptions(String collection,
List<BulkOperation> operations,
BulkWriteOptions bulkWriteOptions,
Handler<AsyncResult<MongoClientBulkWriteResult>> resultHandler)
Execute a bulk operation with the specified write options.
|
MongoClient |
MongoClient.count(String collection,
JsonObject query,
Handler<AsyncResult<Long>> resultHandler)
Count matching documents in a collection.
|
MongoClient |
MongoClient.createCollection(String collectionName,
Handler<AsyncResult<Void>> resultHandler)
Create a new collection
|
MongoClient |
MongoClient.createDefaultGridFsBucketService(Handler<AsyncResult<MongoGridFsClient>> resultHandler)
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
MongoClient |
MongoClient.createGridFsBucketService(String bucketName,
Handler<AsyncResult<MongoGridFsClient>> resultHandler)
Creates a
MongoGridFsClient used to interact with Mongo GridFS. |
MongoClient |
MongoClient.createIndex(String collection,
JsonObject key,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoClient |
MongoClient.createIndexes(String collection,
List<IndexModel> indexes,
Handler<AsyncResult<Void>> resultHandler)
creates an indexes
|
MongoClient |
MongoClient.createIndexWithOptions(String collection,
JsonObject key,
IndexOptions options,
Handler<AsyncResult<Void>> resultHandler)
Creates an index.
|
MongoGridFsClient |
MongoGridFsClient.delete(String id,
Handler<AsyncResult<Void>> resultHandler)
Deletes a file by it's ID
|
MongoClient |
MongoClient.distinct(String collection,
String fieldName,
String resultClassname,
Handler<AsyncResult<JsonArray>> resultHandler)
Gets the distinct values of the specified field name.
|
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.
|
MongoGridFsClient |
MongoGridFsClient.downloadByFileName(WriteStream<Buffer> stream,
String fileName,
Handler<AsyncResult<Long>> resultHandler) |
MongoGridFsClient |
MongoGridFsClient.downloadByFileNameWithOptions(WriteStream<Buffer> stream,
String fileName,
GridFsDownloadOptions options,
Handler<AsyncResult<Long>> resultHandler) |
MongoGridFsClient |
MongoGridFsClient.downloadById(WriteStream<Buffer> stream,
String id,
Handler<AsyncResult<Long>> resultHandler) |
MongoGridFsClient |
MongoGridFsClient.downloadFile(String fileName,
Handler<AsyncResult<Long>> resultHandler)
Downloads a file.
|
MongoGridFsClient |
MongoGridFsClient.downloadFileAs(String fileName,
String newFileName,
Handler<AsyncResult<Long>> resultHandler)
Downloads a file and gives it a new name.
|
MongoGridFsClient |
MongoGridFsClient.downloadFileByID(String id,
String fileName,
Handler<AsyncResult<Long>> resultHandler)
Downloads a file using the ID generated by GridFs.
|
MongoGridFsClient |
MongoGridFsClient.drop(Handler<AsyncResult<Void>> resultHandler)
Drops the entire file bucket with all of its contents
|
MongoClient |
MongoClient.dropCollection(String collection,
Handler<AsyncResult<Void>> resultHandler)
Drop a collection
|
MongoClient |
MongoClient.dropIndex(String collection,
String indexName,
Handler<AsyncResult<Void>> resultHandler)
Drops the index given its name.
|
MongoClient |
MongoClient.find(String collection,
JsonObject query,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection
|
MongoGridFsClient |
MongoGridFsClient.findAllIds(Handler<AsyncResult<List<String>>> resultHandler)
Finds all file ids in the bucket
|
MongoGridFsClient |
MongoGridFsClient.findIds(JsonObject query,
Handler<AsyncResult<List<String>>> resultHandler)
Finds all file ids that match a query.
|
MongoClient |
MongoClient.findOne(String collection,
JsonObject query,
JsonObject fields,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection
|
MongoClient |
MongoClient.findOneAndDelete(String collection,
JsonObject query,
Handler<AsyncResult<JsonObject>> resultHandler)
Find a single matching document in the specified collection and delete it.
|
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.
|
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.
|
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.
|
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.
|
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.
|
MongoClient |
MongoClient.findWithOptions(String collection,
JsonObject query,
FindOptions options,
Handler<AsyncResult<List<JsonObject>>> resultHandler)
Find matching documents in the specified collection, specifying options
|
MongoClient |
MongoClient.getCollections(Handler<AsyncResult<List<String>>> resultHandler)
Get a list of all collections in the database.
|
MongoClient |
MongoClient.insert(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Insert a document in the specified collection
|
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
|
MongoClient |
MongoClient.listIndexes(String collection,
Handler<AsyncResult<JsonArray>> resultHandler)
Get all the indexes in this collection.
|
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
|
MongoClient |
MongoClient.removeDocuments(String collection,
JsonObject query,
Handler<AsyncResult<MongoClientDeleteResult>> resultHandler)
Remove matching documents from a collection and return the handler with MongoClientDeleteResult result
|
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
|
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
|
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
|
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
|
MongoClient |
MongoClient.runCommand(String commandName,
JsonObject command,
Handler<AsyncResult<JsonObject>> resultHandler)
Run an arbitrary MongoDB command.
|
MongoClient |
MongoClient.save(String collection,
JsonObject document,
Handler<AsyncResult<String>> resultHandler)
Save a document in the specified collection
|
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
|
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
|
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
|
MongoGridFsClient |
MongoGridFsClient.uploadByFileName(ReadStream<Buffer> stream,
String fileName,
Handler<AsyncResult<String>> resultHandler) |
MongoGridFsClient |
MongoGridFsClient.uploadByFileNameWithOptions(ReadStream<Buffer> stream,
String fileName,
GridFsUploadOptions options,
Handler<AsyncResult<String>> resultHandler) |
MongoGridFsClient |
MongoGridFsClient.uploadFile(String fileName,
Handler<AsyncResult<String>> resultHandler)
Upload a file to gridfs
|
MongoGridFsClient |
MongoGridFsClient.uploadFileWithOptions(String fileName,
GridFsUploadOptions options,
Handler<AsyncResult<String>> resultHandler)
Upload a file to gridfs with options
|
| 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.
|
SQLOperations |
SQLOperations.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. |
SQLConnection |
SQLConnection.call(String sql,
Handler<AsyncResult<ResultSet>> resultHandler)
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. |
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. |
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. |
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.
|
SQLOperations |
SQLOperations.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.
|
SQLConnection |
SQLConnection.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.
|
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. |
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. |
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. |
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. |
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. |
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. |
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. |
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.
|
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. |
SQLRowStream |
SQLRowStream.resultSetClosedHandler(Handler<Void> handler)
Event handler when a resultset is closed.
|
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.setOptions(SQLOptions options)
Sets the desired options to be applied to the current connection when statements are executed.
|
default SQLConnection |
SQLConnection.setQueryTimeout(int timeoutInSeconds)
Deprecated.
instead use
SQLConnection.setOptions(SQLOptions) with SQLOptions.setQueryTimeout(int) |
SQLConnection |
SQLConnection.setTransactionIsolation(TransactionIsolation isolation,
Handler<AsyncResult<Void>> handler)
Attempts to change the transaction isolation level for this Connection object to the one given.
|
SQLOperations |
SQLOperations.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. |
SQLConnection |
SQLConnection.update(String sql,
Handler<AsyncResult<UpdateResult>> resultHandler)
Executes the given SQL statement which may be an
INSERT, UPDATE, or DELETE
statement. |
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 |
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 |
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 |
| Modifier and Type | Method and Description |
|---|---|
TestSuite |
TestSuite.after(Handler<TestContext> callback)
Set a callback executed after the tests.
|
TestSuite |
TestSuite.afterEach(Handler<TestContext> callback)
Set a callback executed after each test and before the suite
after callback. |
TestContext |
TestContext.assertEquals(Object expected,
Object actual)
Assert the
expected argument is equals to the actual argument. |
TestContext |
TestContext.assertEquals(Object expected,
Object actual,
String message)
Assert the
expected argument is equals to the actual argument. |
TestContext |
TestContext.assertFalse(boolean condition)
Assert the specified
condition is false. |
TestContext |
TestContext.assertFalse(boolean condition,
String message)
Assert the specified
condition is false. |
TestContext |
TestContext.assertInRange(double expected,
double actual,
double delta)
Asserts that the
expected double argument is equals to the actual double argument
within a positive delta. |
TestContext |
TestContext.assertInRange(double expected,
double actual,
double delta,
String message)
Asserts that the
expected double argument is equals to the actual double argument
within a positive delta. |
TestContext |
TestContext.assertNotEquals(Object first,
Object second)
Assert the
first argument is not equals to the second argument. |
TestContext |
TestContext.assertNotEquals(Object first,
Object second,
String message)
Assert the
first argument is not equals to the second argument. |
TestContext |
TestContext.assertNotNull(Object expected)
Assert the
expected argument is not null. |
TestContext |
TestContext.assertNotNull(Object expected,
String message)
Assert the
expected argument is not null. |
TestContext |
TestContext.assertNull(Object expected)
Assert the
expected argument is null. |
TestContext |
TestContext.assertNull(Object expected,
String message)
Assert the
expected argument is null. |
TestContext |
TestContext.assertTrue(boolean condition)
Assert the specified
condition is true. |
TestContext |
TestContext.assertTrue(boolean condition,
String message)
Assert the specified
condition is true. |
TestSuite |
TestSuite.before(Handler<TestContext> callback)
Set a callback executed before the tests.
|
TestSuite |
TestSuite.beforeEach(Handler<TestContext> callback)
Set a callback executed before each test and after the suite
before callback. |
TestOptions |
TestOptions.setTimeout(long timeout)
Set the test timeout.
|
TestOptions |
TestOptions.setUseEventLoop(Boolean useEventLoop)
Configure the execution to use an event loop when there is no one existing.
|
TestSuite |
TestSuite.test(String name,
Handler<TestContext> testCase)
Add a new test case to the suite.
|
TestSuite |
TestSuite.test(String name,
int repeat,
Handler<TestContext> testCase)
Add a new test case to the suite.
|
TestContext |
TestContext.verify(Handler<Void> block)
Execute the provided handler, which may contain assertions, possibly from any third-party assertion framework.
|
| Modifier and Type | Method and Description |
|---|---|
ReportingOptions |
ReportingOptions.addReporter(ReportOptions reportOptions)
Add a reporter to the current list.
|
TestCaseReport |
TestCaseReport.endHandler(Handler<TestResult> handler)
Set a callback for completion, the specified
handler is invoked when the test exec has completed. |
ReportOptions |
ReportOptions.setFormat(String format)
Set the current reporter format.
|
ReportingOptions |
ReportingOptions.setReporters(List<ReportOptions> reporters)
Replace the current list of reporters with a new one.
|
ReportOptions |
ReportOptions.setTo(String to)
Set the current reporter name.
|
| Modifier and Type | Method and Description |
|---|---|
RoutingContext |
RoutingContext.addCookie(Cookie cookie)
Add a cookie.
|
Router |
Router.allowForward(AllowForwardHeaders allowForwardHeaders)
Set whether the router should parse "forwarded"-type headers
|
default RoutingContext |
RoutingContext.attachment(String filename)
Set Content-Disposition get to "attachment" with optional
filename mime type. |
Route |
Route.blockingHandler(Handler<RoutingContext> requestHandler)
Like
Route.blockingHandler(Handler, boolean) called with ordered = true |
Route |
Route.blockingHandler(Handler<RoutingContext> requestHandler,
boolean ordered)
Specify a blocking request handler for the route.
|
Router |
Router.clear()
Remove all the routes from this router
|
Session |
Session.computeIfAbsent(String key,
Function<String,Object> mappingFunction)
Put some data in a session if absent.
|
Route |
Route.consumes(String contentType)
Add a content type consumed by this route.
|
Route |
Route.disable()
Disable this route.
|
Route |
Route.enable()
Enable this route.
|
default RoutingContext |
RoutingContext.end(Buffer buffer,
Handler<AsyncResult<Void>> handler)
|
default RoutingContext |
RoutingContext.end(Handler<AsyncResult<Void>> handler)
|
default RoutingContext |
RoutingContext.end(String chunk,
Handler<AsyncResult<Void>> handler)
|
Router |
Router.errorHandler(int statusCode,
Handler<RoutingContext> errorHandler)
Specify an handler to handle an error for a particular status code.
|
default RoutingContext |
RoutingContext.etag(String etag)
Set the ETag of a response.
|
Route |
Route.failureHandler(Handler<RoutingContext> failureHandler)
Append a failure handler to the route failure handlers list.
|
Route |
Route.handler(Handler<RoutingContext> requestHandler)
Append a request handler to the route handlers list.
|
default RoutingContext |
RoutingContext.json(Object json,
Handler<AsyncResult<Void>> handler)
|
Route |
Route.last()
Specify this is the last route for the router.
|
default RoutingContext |
RoutingContext.lastModified(Instant instant)
Set the Last-Modified date using a Instant.
|
default RoutingContext |
RoutingContext.lastModified(String instant)
Set the Last-Modified date using a String.
|
Route |
Route.method(HttpMethod method)
Add an HTTP method for this route.
|
Router |
Router.modifiedHandler(Handler<Router> handler)
When a Router routes are changed this handler is notified.
|
Route |
Route.order(int order)
Specify the order for this route.
|
Route |
Route.path(String path)
Set the path prefix for this route.
|
Route |
Route.pathRegex(String path)
Set the path prefix as a regular expression.
|
Route |
Route.produces(String contentType)
Add a content type produced by this route.
|
Session |
Session.put(String key,
Object obj)
Put some data in a session
|
RoutingContext |
RoutingContext.put(String key,
Object obj)
Put some arbitrary data in the context.
|
Session |
Session.putIfAbsent(String key,
Object obj)
Put some data in a session if absent
|
default RoutingContext |
RoutingContext.redirect(String url,
Handler<AsyncResult<Void>> handler)
|
Route |
Route.remove()
Remove this route from the router
|
default <T> Route |
Route.respond(Function<RoutingContext,Future<T>> function)
Append a function request handler to the route handlers list.
|
Route |
Route.setName(String name)
Giving a name to a route will provide this name as metadata to requests matching this route.
|
Route |
Route.setRegexGroupsNames(List<String> groups)
When you add a new route with a regular expression, you can add named capture groups for parameters.
|
Route |
Route.subRouter(Router subRouter)
Use a (sub)
Router as a handler. |
default Route |
Route.useNormalisedPath(boolean useNormalizedPath)
Deprecated.
|
Route |
Route.useNormalizedPath(boolean useNormalizedPath)
If true then the normalized request path will be used when routing (e.g.
|
Route |
Route.virtualHost(String hostnamePattern)
Add a virtual host filter for this route.
|
| Modifier and Type | Method and Description |
|---|---|
OperationResponse |
OperationResponse.putHeader(String key,
String value)
Deprecated.
|
OperationRequest |
OperationRequest.setExtra(JsonObject extra)
Deprecated.
|
OperationResponse |
OperationResponse.setHeaders(MultiMap headers)
Deprecated.
|
OperationRequest |
OperationRequest.setHeaders(MultiMap headers)
Deprecated.
|
OperationRequest |
OperationRequest.setParams(JsonObject params)
Deprecated.
|
OperationResponse |
OperationResponse.setPayload(Buffer payload)
Deprecated.
|
OperationResponse |
OperationResponse.setStatusCode(Integer statusCode)
Deprecated.
|
OperationResponse |
OperationResponse.setStatusMessage(String statusMessage)
Deprecated.
|
OperationRequest |
OperationRequest.setUser(JsonObject user)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
RouterFactory |
RouterFactory.addGlobalHandler(Handler<RoutingContext> globalHandler)
Deprecated.
Add global handler to be applied prior to
Router being generated. |
RouterFactory |
RouterFactory.addSecurityHandler(String securitySchemaName,
Handler<RoutingContext> handler)
Deprecated.
Mount to paths that have to follow a security schema a security handler
|
RouterFactory |
RouterFactory.setBodyHandler(BodyHandler bodyHandler)
Deprecated.
Supply your own BodyHandler if you would like to control body limit, uploads directory and deletion of uploaded files
|
RouterFactory |
RouterFactory.setExtraOperationContextPayloadMapper(Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper)
Deprecated.
When set, this function is called while creating the payload of
OperationRequest |
RouterFactoryOptions |
RouterFactoryOptions.setMountNotImplementedHandler(boolean mountOperationsWithoutHandler)
Deprecated.
If true, Router Factory will automatically mount an handler that return HTTP 405/501 status code for each operation where you didn't specify an handler.
|
RouterFactoryOptions |
RouterFactoryOptions.setMountResponseContentTypeHandler(boolean mountResponseContentTypeHandler)
Deprecated.
If true, when required, the factory will mount a
ResponseContentTypeHandler |
RouterFactoryOptions |
RouterFactoryOptions.setMountValidationFailureHandler(boolean mountGlobalValidationFailureHandler)
Deprecated.
Router Factory won't manage the validation errors anymore. You must use
Router.errorHandler(int, Handler) with 400 error |
RouterFactory |
RouterFactory.setNotImplementedFailureHandler(Handler<RoutingContext> notImplementedFailureHandler)
Deprecated.
You must use
Router.errorHandler(int, Handler) with 501 error |
RouterFactoryOptions |
RouterFactoryOptions.setOperationModelKey(String operationModelKey)
Deprecated.
When set, an additional handler will be created to expose the operation model in the routing
context under the given key.
|
RouterFactory |
RouterFactory.setOptions(RouterFactoryOptions options)
Deprecated.
Set options of router factory.
|
RouterFactoryOptions |
RouterFactoryOptions.setRequireSecurityHandlers(boolean requireSecurityHandlers)
Deprecated.
If true, when you call
RouterFactory.getRouter() the factory will mount for every path
the required security handlers and, if a security handler is not defined, it throws an RouterFactoryException |
RouterFactory |
RouterFactory.setValidationFailureHandler(Handler<RoutingContext> validationFailureHandler)
Deprecated.
Router Factory won't manage the validation errors anymore. You must use
Router.errorHandler(int, Handler) with 400 error |
| Modifier and Type | Method and Description |
|---|---|
RouterFactory |
BaseRouterFactory.addGlobalHandler(Handler<RoutingContext> globalHandler) |
RouterFactory |
BaseRouterFactory.setBodyHandler(BodyHandler bodyHandler) |
RouterFactory |
BaseRouterFactory.setExtraOperationContextPayloadMapper(Function<RoutingContext,JsonObject> extraOperationContextPayloadMapper) |
RouterFactory |
BaseRouterFactory.setNotImplementedFailureHandler(Handler<RoutingContext> notImplementedFailureHandler) |
RouterFactory |
BaseRouterFactory.setValidationFailureHandler(Handler<RoutingContext> validationFailureHandler) |
| Modifier and Type | Method and Description |
|---|---|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.addFailureHandlerByOperationId(String operationId,
Handler<RoutingContext> failureHandler)
Deprecated.
Add a failure handler by operation_id field in Operation object
|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.addHandlerByOperationId(String operationId,
Handler<RoutingContext> handler)
Deprecated.
Add an handler by operation_id field in Operation object
|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.addSecuritySchemaScopeValidator(String securitySchemaName,
String scopeName,
Handler<RoutingContext> handler)
Deprecated.
Add a particular scope validator.
|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.mountOperationToEventBus(String operationId,
String address)
Deprecated.
Specify to route an incoming request for specified operation id to a Web Api Service mounted at the specified address on event bus.
|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.mountServiceFromTag(String tag,
String address)
Deprecated.
Specify to route an incoming request for all operations that contains the specified tag to a Web Api Service mounted at the specified address on event bus.
|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.mountServiceInterface(Class interfaceClass,
String address)
Deprecated.
Introspect the Web Api Service interface to route to service all matching method names with operation ids.
|
OpenAPI3RouterFactory |
OpenAPI3RouterFactory.mountServicesFromExtensions()
Deprecated.
Introspect the OpenAPI spec to mount handlers for all operations that specifies a x-vertx-event-bus annotation.
|
| Modifier and Type | Method and Description |
|---|---|
RouteToEBServiceHandler |
RouteToEBServiceHandler.extraPayloadMapper(Function<RoutingContext,JsonObject> extraPayloadMapper)
When
extraPayloadMapper is configured, this handler puts the evaluation result into ServiceRequest.getExtra() |
ServiceResponse |
ServiceResponse.putHeader(String key,
String value) |
ServiceRequest |
ServiceRequest.setExtra(JsonObject extra) |
ServiceResponse |
ServiceResponse.setHeaders(MultiMap headers) |
ServiceRequest |
ServiceRequest.setHeaders(MultiMap headers) |
ServiceRequest |
ServiceRequest.setParams(JsonObject params) |
ServiceResponse |
ServiceResponse.setPayload(Buffer payload) |
ServiceResponse |
ServiceResponse.setStatusCode(Integer statusCode) |
ServiceResponse |
ServiceResponse.setStatusMessage(String statusMessage) |
ServiceRequest |
ServiceRequest.setUser(JsonObject user) |
| Modifier and Type | Method and Description |
|---|---|
RouteToEBServiceHandlerImpl |
RouteToEBServiceHandlerImpl.extraPayloadMapper(Function<RoutingContext,JsonObject> extraPayloadMapper) |
| Modifier and Type | Method and Description |
|---|---|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addCustomValidatorFunction(CustomValidator customValidator)
Deprecated.
Add a custom validator.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addExpectedContentType(String contentType)
Deprecated.
Add an expected content type of request.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addFormParam(String parameterName,
ParameterType type,
boolean required)
Deprecated.
Add a single parameter inside a form with included parameter types
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addFormParamsArray(String parameterName,
ParameterType type,
boolean required)
Deprecated.
Add a form parameters array with included parameter types
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addFormParamsArrayWithPattern(String parameterName,
String pattern,
boolean required)
Deprecated.
Add a form parameters array with a custom pattern
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addFormParamWithCustomTypeValidator(String parameterName,
ParameterTypeValidator validator,
boolean required,
boolean allowEmptyValue)
Deprecated.
Add a form parameter with a custom type validator.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addFormParamWithPattern(String parameterName,
String pattern,
boolean required)
Deprecated.
Add a single parameter inside a form with a custom pattern
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addHeaderParam(String headerName,
ParameterType type,
boolean required)
Deprecated.
Add a header parameter with included parameter types
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addHeaderParamWithCustomTypeValidator(String headerName,
ParameterTypeValidator validator,
boolean required,
boolean allowEmptyValue)
Deprecated.
Add a header parameter with a custom type validator.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addHeaderParamWithPattern(String headerName,
String pattern,
boolean required)
Deprecated.
Add a header parameter with a custom pattern
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addJsonBodySchema(String jsonSchema)
Deprecated.
Add a json schema for body with Content-Type "application/json"
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addMultipartRequiredFile(String filename,
String contentType)
Deprecated.
Add an expected filename inside multipart request.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addPathParam(String parameterName,
ParameterType type)
Deprecated.
Add a path parameter with included parameter types.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addPathParamWithCustomTypeValidator(String parameterName,
ParameterTypeValidator validator,
boolean allowEmptyValue)
Deprecated.
Add a path parameter with a custom type validator.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addPathParamWithPattern(String parameterName,
String pattern)
Deprecated.
Add a path parameter with a custom pattern.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addQueryParam(String parameterName,
ParameterType type,
boolean required)
Deprecated.
Add a query parameter with included parameter types
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addQueryParamsArray(String arrayName,
ParameterType type,
boolean required)
Deprecated.
Add a query parameters array with included parameter types
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addQueryParamsArrayWithPattern(String arrayName,
String pattern,
boolean required)
Deprecated.
Add a query parameters array with a custom pattern
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addQueryParamWithCustomTypeValidator(String parameterName,
ParameterTypeValidator validator,
boolean required,
boolean allowEmptyValue)
Deprecated.
Add a query parameter with a custom type validator.
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addQueryParamWithPattern(String parameterName,
String pattern,
boolean required)
Deprecated.
Add a query parameter with a custom pattern
|
HTTPRequestValidationHandler |
HTTPRequestValidationHandler.addXMLBodySchema(String xmlSchema)
Deprecated.
Add a xml schema for body with Content-Type "application/xml"
|
| Modifier and Type | Method and Description |
|---|---|
WebClientSession |
WebClientSession.addHeader(CharSequence name,
CharSequence value)
Configure the client to add an HTTP header to every request.
|
WebClientSession |
WebClientSession.addHeader(CharSequence name,
Iterable<CharSequence> values)
Configure the client to add an HTTP header to every request.
|
WebClientSession |
WebClientSession.addHeader(String name,
Iterable<String> values)
Configure the client to add an HTTP header to every request.
|
WebClientSession |
WebClientSession.addHeader(String name,
String value)
Configure the client to add an HTTP header to every request.
|
HttpRequest<T> |
HttpRequest.addQueryParam(String paramName,
String paramValue)
Add a query parameter to the request.
|
HttpRequest<T> |
HttpRequest.authentication(Credentials credentials)
Configure the request to perform HTTP Authentication.
|
default HttpRequest<T> |
HttpRequest.basicAuthentication(Buffer id,
Buffer password)
Configure the request to perform basic access authentication.
|
default HttpRequest<T> |
HttpRequest.basicAuthentication(String id,
String password)
Configure the request to perform basic access authentication.
|
default HttpRequest<T> |
HttpRequest.bearerTokenAuthentication(String bearerToken)
Configure the request to perform bearer token authentication.
|
default HttpRequest<T> |
HttpRequest.expect(Function<HttpResponse<Void>,ResponsePredicateResult> predicate)
Add an expectation that the response is valid according to the provided
predicate. |
HttpRequest<T> |
HttpRequest.expect(ResponsePredicate predicate)
Add an expectation that the response is valid according to the provided
predicate. |
HttpRequest<T> |
HttpRequest.followRedirects(boolean value)
Set wether or not to follow the directs for the request.
|
HttpRequest<T> |
HttpRequest.host(String value)
Configure the request to use a new host
value. |
HttpRequest<T> |
HttpRequest.method(HttpMethod value)
Configure the request to use a new method
value. |
HttpRequest<T> |
HttpRequest.port(int value)
Configure the request to use a new port
value. |
HttpRequest<T> |
HttpRequest.putHeader(String name,
Iterable<String> value)
Configure the request to set a new HTTP header with multiple values.
|
HttpRequest<T> |
HttpRequest.putHeader(String name,
String value)
Configure the request to set a new HTTP header.
|
HttpRequest<T> |
HttpRequest.putHeaders(MultiMap headers)
Configure the request to add multiple HTTP headers .
|
WebClientSession |
WebClientSession.removeHeader(CharSequence name)
Removes a previously added header.
|
WebClientSession |
WebClientSession.removeHeader(String name)
Removes a previously added header.
|
HttpRequest<T> |
HttpRequest.setQueryParam(String paramName,
String paramValue)
Set a query parameter to the request.
|
HttpRequest<T> |
HttpRequest.ssl(Boolean value) |
HttpRequest<T> |
HttpRequest.timeout(long value)
Configures the amount of time in milliseconds after which if the request does not return any data within the timeout
period an
TimeoutException fails the request. |
HttpRequest<T> |
HttpRequest.uri(String value)
Configure the request to use a new request URI
value. |
HttpRequest<T> |
HttpRequest.virtualHost(String value)
Configure the request to use a virtual host
value. |
| Modifier and Type | Method and Description |
|---|---|
ChainAuthHandler |
ChainAuthHandler.add(AuthenticationHandler other)
Appends a auth provider to the chain.
|
AuthHandler |
AuthHandler.addAuthorities(Set<String> authorities)
Deprecated.
this functionality is now handled by the new
AuthorizationProvider |
AuthHandler |
AuthHandler.addAuthority(String authority)
Deprecated.
this functionality is now handled by the new
AuthorizationProvider |
AuthorizationHandler |
AuthorizationHandler.addAuthorizationProvider(AuthorizationProvider authorizationProvider)
Adds a provider that shall be used to retrieve the required authorizations for the user to attest.
|
MultiTenantHandler |
MultiTenantHandler.addDefaultHandler(Handler<RoutingContext> handler)
Add a default handler for the case when no tenant was matched.
|
CSPHandler |
CSPHandler.addDirective(String name,
String value)
Adds a single directive entry to the handler.
|
CorsHandler |
CorsHandler.addOrigin(String origin)
Add an origin to the list of allowed Origins.
|
CorsHandler |
CorsHandler.addOrigins(List<String> origins)
Set the list of allowed origins.
|
MultiTenantHandler |
MultiTenantHandler.addTenantHandler(String tenant,
Handler<RoutingContext> handler)
Add a handler for a given tenant to this handler.
|
CorsHandler |
CorsHandler.allowCredentials(boolean allow)
Set whether credentials are allowed.
|
CorsHandler |
CorsHandler.allowedHeader(String headerName)
Add an allowed header
|
CorsHandler |
CorsHandler.allowedHeaders(Set<String> headerNames)
Add a set of allowed headers
|
CorsHandler |
CorsHandler.allowedMethod(HttpMethod method)
Add an allowed method
|
CorsHandler |
CorsHandler.allowedMethods(Set<HttpMethod> methods)
Add a set of allowed methods
|
LoggerHandler |
LoggerHandler.customFormatter(Function<HttpServerRequest,String> formatter)
Set the custom formatter to be used by the handler.
|
CorsHandler |
CorsHandler.exposedHeader(String headerName)
Add an exposed header
|
CorsHandler |
CorsHandler.exposedHeaders(Set<String> headerNames)
Add a set of exposed headers
|
OAuth2AuthHandler |
OAuth2AuthHandler.extraParams(JsonObject extraParams)
Extra parameters needed to be passed while requesting a token.
|
SessionHandler |
SessionHandler.flush(RoutingContext ctx,
boolean ignoreStatus,
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.
|
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.
|
CorsHandler |
CorsHandler.maxAgeSeconds(int maxAgeSeconds)
Set how long the browser should cache the information
|
OAuth2AuthHandler |
OAuth2AuthHandler.pkceVerifierLength(int length)
PKCE (RFC 7636) is an extension to the Authorization Code flow to prevent several attacks and to be able to
securely perform the OAuth exchange from public clients.
|
OAuth2AuthHandler |
OAuth2AuthHandler.prompt(String prompt)
Indicates the type of user interaction that is required.
|
MultiTenantHandler |
MultiTenantHandler.removeTenant(String tenant)
Remove a handler for a given tenant from this handler.
|
StaticHandler |
StaticHandler.setAllowRootFileSystemAccess(boolean allowRootFileSystemAccess)
Enable/Disable access to the root of the filesystem
|
StaticHandler |
StaticHandler.setAlwaysAsyncFS(boolean alwaysAsyncFS)
Set whether async filesystem access should always be used
|
SessionHandler |
SessionHandler.setAuthProvider(AuthProvider authProvider)
Deprecated.
this method has no effect
|
BodyHandler |
BodyHandler.setBodyLimit(long bodyLimit)
Set the maximum body size in bytes,
-1 means no limit |
StaticHandler |
StaticHandler.setCacheEntryTimeout(long timeout)
Set the server cache entry timeout when caching is enabled
|
StaticHandler |
StaticHandler.setCachingEnabled(boolean enabled)
Set whether cache header handling is enabled
|
CSRFHandler |
CSRFHandler.setCookieHttpOnly(boolean httpOnly)
Set the cookie
httpOnly attribute. |
SessionHandler |
SessionHandler.setCookieHttpOnlyFlag(boolean httpOnly)
Sets whether the 'HttpOnly' flag should be set for the session cookie.
|
SessionHandler |
SessionHandler.setCookieless(boolean cookieless)
Use sessions based on url paths instead of cookies.
|
SessionHandler |
SessionHandler.setCookieMaxAge(long cookieMaxAge)
Set a Cookie max-age to the session cookie.
|
CSRFHandler |
CSRFHandler.setCookieName(String name)
Set the cookie name.
|
CSRFHandler |
CSRFHandler.setCookiePath(String path)
Set the cookie path.
|
SessionHandler |
SessionHandler.setCookieSameSite(CookieSameSite policy)
Set the session cookie SameSite policy to use.
|
SessionHandler |
SessionHandler.setCookieSecureFlag(boolean secure)
Sets whether the 'secure' flag should be set for the session cookie.
|
StaticHandler |
StaticHandler.setDefaultContentEncoding(String contentEncoding)
Set the default content encoding for text related files.
|
BodyHandler |
BodyHandler.setDeleteUploadedFilesOnEnd(boolean deleteUploadedFilesOnEnd)
Set whether uploaded files should be removed after handling the request
|
CSPHandler |
CSPHandler.setDirective(String name,
String value)
Sets a single directive entry to the handler.
|
FormLoginHandler |
FormLoginHandler.setDirectLoggedInOKURL(String directLoggedInOKURL)
Set the url to redirect to if the user logs in directly at the url of the form login handler
without being redirected here first
|
StaticHandler |
StaticHandler.setDirectoryListing(boolean directoryListing)
Set whether directory listing is enabled
|
StaticHandler |
StaticHandler.setDirectoryTemplate(String directoryTemplate)
Set the directory template to be used when directory listing
|
StaticHandler |
StaticHandler.setEnableFSTuning(boolean enableFSTuning)
Set whether async/sync filesystem tuning should enabled
|
StaticHandler |
StaticHandler.setEnableRangeSupport(boolean enableRangeSupport)
Set whether range requests (resumable downloads; media streaming) should be enabled.
|
StaticHandler |
StaticHandler.setFilesReadOnly(boolean readOnly)
Set whether files are read-only and will never change
|
BodyHandler |
BodyHandler.setHandleFileUploads(boolean handleFileUploads)
Set whether file uploads will be handled
|
CSRFHandler |
CSRFHandler.setHeaderName(String name)
Set the header name.
|
StaticHandler |
StaticHandler.setHttp2PushMapping(List<Http2PushMapping> http2PushMappings)
Set the file mapping for http2push and link preload
|
StaticHandler |
StaticHandler.setIncludeHidden(boolean includeHidden)
Set whether hidden files should be served
|
StaticHandler |
StaticHandler.setIndexPage(String indexPage)
Set the index page
|
TemplateHandler |
TemplateHandler.setIndexTemplate(String indexTemplate)
Set the index template
|
SessionHandler |
SessionHandler.setLazySession(boolean lazySession)
Use a lazy session creation mechanism.
|
StaticHandler |
StaticHandler.setMaxAgeSeconds(long maxAgeSeconds)
Set value for max age in caching headers
|
StaticHandler |
StaticHandler.setMaxAvgServeTimeNs(long maxAvgServeTimeNanoSeconds)
Set the max serve time in ns, above which serves are considered slow
|
StaticHandler |
StaticHandler.setMaxCacheSize(int maxCacheSize)
Set the max cache size, when caching is enabled
|
BodyHandler |
BodyHandler.setMergeFormAttributes(boolean mergeFormAttributes)
Set whether form attributes will be added to the request parameters
|
SessionHandler |
SessionHandler.setMinLength(int minLength)
Set expected session id minimum length.
|
SessionHandler |
SessionHandler.setNagHttps(boolean nag)
Set whether a nagging log warning should be written if the session handler is
accessed over HTTP, not HTTPS
|
CSRFHandler |
CSRFHandler.setNagHttps(boolean nag)
Should the handler give warning messages if this handler is used in other than https protocols?
|
WebAuthnHandler |
WebAuthnHandler.setOrigin(String origin)
Set the Origin to be validated by the webauthn object.
|
CSRFHandler |
CSRFHandler.setOrigin(String origin)
Set the origin for this server.
|
FormLoginHandler |
FormLoginHandler.setPasswordParam(String passwordParam)
Set the name of the form param used to submit the password
|
BodyHandler |
BodyHandler.setPreallocateBodyBuffer(boolean isPreallocateBodyBuffer)
Pre-allocate the body buffer according to the value parsed from content-length header.
|
CSPHandler |
CSPHandler.setReportOnly(boolean reportOnly)
To ease deployment, CSP can be deployed in report-only mode.
|
FormLoginHandler |
FormLoginHandler.setReturnURLParam(String returnURLParam)
Set the name of the session attrioute used to specify the return url
|
StaticHandler |
StaticHandler.setSendVaryHeader(boolean varyHeader)
Set whether vary header should be sent with response.
|
SessionHandler |
SessionHandler.setSessionCookieName(String sessionCookieName)
Set the session cookie name
|
SessionHandler |
SessionHandler.setSessionCookiePath(String sessionCookiePath)
Set the session cookie path
|
SessionHandler |
SessionHandler.setSessionTimeout(long timeout)
Set the session timeout
|
CSRFHandler |
CSRFHandler.setTimeout(long timeout)
Set the timeout for tokens generated by the handler, by default it uses the default from the session handler.
|
WebAuthnHandler |
WebAuthnHandler.setupCallback(Route route)
The callback route to verify attestations and assertions.
|
OAuth2AuthHandler |
OAuth2AuthHandler.setupCallback(Route route)
add the callback handler to a given route.
|
WebAuthnHandler |
WebAuthnHandler.setupCredentialsCreateCallback(Route route)
The callback route to create registration attestations.
|
WebAuthnHandler |
WebAuthnHandler.setupCredentialsGetCallback(Route route)
The callback route to create login attestations.
|
BodyHandler |
BodyHandler.setUploadsDirectory(String uploadsDirectory)
Set the uploads directory to use
|
default SessionHandler |
SessionHandler.setUser(RoutingContext context,
User user,
Handler<AsyncResult<Void>> handler)
Set the user for the session
|
FormLoginHandler |
FormLoginHandler.setUsernameParam(String usernameParam)
Set the name of the form param used to submit the username
|
StaticHandler |
StaticHandler.setWebRoot(String webRoot)
Set the web root
|
StaticHandler |
StaticHandler.skipCompressionForMediaTypes(Set<String> mediaTypes)
Skip compression if the media type of the file to send is in the provided
mediaTypes set. |
StaticHandler |
StaticHandler.skipCompressionForSuffixes(Set<String> fileSuffixes)
Skip compression if the suffix of the file to send is in the provided
fileSuffixes set. |
AuthorizationHandler |
AuthorizationHandler.variableConsumer(BiConsumer<RoutingContext,AuthorizationContext> handler)
Provide a simple handler to extract needed variables.
|
OAuth2AuthHandler |
OAuth2AuthHandler.withScope(String scope)
scopes to be requested while requesting a token.
|
| Modifier and Type | Method and Description |
|---|---|
ApolloWSHandler |
ApolloWSHandler.connectionHandler(Handler<ServerWebSocket> connectionHandler)
Customize the connection
Handler. |
ApolloWSHandler |
ApolloWSHandler.connectionInitHandler(Handler<ApolloWSConnectionInitEvent> connectionInitHandler)
Customize the connection init
Handler. |
ApolloWSHandler |
ApolloWSHandler.dataLoaderRegistry(Function<ApolloWSMessage,org.dataloader.DataLoaderRegistry> factory)
Customize the
DataLoaderRegistry. |
GraphQLHandler |
GraphQLHandler.dataLoaderRegistry(Function<RoutingContext,org.dataloader.DataLoaderRegistry> factory)
Customize the
DataLoaderRegistry. |
ApolloWSHandler |
ApolloWSHandler.endHandler(Handler<ServerWebSocket> endHandler)
Customize the end
Handler. |
GraphiQLHandler |
GraphiQLHandler.graphiQLRequestHeaders(Function<RoutingContext,MultiMap> factory)
Customize the HTTP headers to add to GraphQL requests sent by the GraphiQL user interface.
|
ApolloWSHandler |
ApolloWSHandler.locale(Function<ApolloWSMessage,Locale> factory)
Customize the
Locale passed to the GraphQL execution engine. |
GraphQLHandler |
GraphQLHandler.locale(Function<RoutingContext,Locale> factory)
Customize the
Locale passed to the GraphQL execution engine. |
ApolloWSHandler |
ApolloWSHandler.messageHandler(Handler<ApolloWSMessage> messageHandler)
Customize the message
Handler. |
ApolloWSHandler |
ApolloWSHandler.queryContext(Function<ApolloWSMessage,Object> factory)
Customize the query context object.
|
GraphQLHandler |
GraphQLHandler.queryContext(Function<RoutingContext,Object> factory)
Customize the query context object.
|
| Modifier and Type | Method and Description |
|---|---|
BridgeEvent |
BridgeEvent.setRawMessage(JsonObject message)
Set the raw JSON message for the event.
|
| Modifier and Type | Method and Description |
|---|---|
MultipartForm |
MultipartForm.attribute(String name,
String value)
Add an attribute form data part.
|
MultipartForm |
MultipartForm.binaryFileUpload(String name,
String filename,
Buffer content,
String mediaType)
Add a binary file upload form data part.
|
MultipartForm |
MultipartForm.binaryFileUpload(String name,
String filename,
String pathname,
String mediaType)
Add a binary file upload form data part.
|
MultipartForm |
MultipartForm.textFileUpload(String name,
String filename,
Buffer content,
String mediaType)
Add a text file upload form data part.
|
MultipartForm |
MultipartForm.textFileUpload(String name,
String filename,
String pathname,
String mediaType)
Add a text file upload form data part.
|
| Modifier and Type | Method and Description |
|---|---|
RouterBuilder |
RouterBuilder.bodyHandler(BodyHandler bodyHandler)
Supply your own BodyHandler if you would like to control body limit, uploads directory and deletion of uploaded
files.
|
Operation |
Operation.failureHandler(Handler<RoutingContext> handler)
Mount a failure handler for this operation
|
Operation |
Operation.handler(Handler<RoutingContext> handler)
Mount an handler for this operation
|
RouterBuilder |
RouterBuilder.mountServiceInterface(Class interfaceClass,
String address)
Introspect the Web Api Service interface to route to service all matching method names with operation ids.
|
RouterBuilder |
RouterBuilder.mountServicesFromExtensions()
Introspect the OpenAPI spec to mount handlers for all operations that specifies a x-vertx-event-bus annotation.
|
OpenAPILoaderOptions |
OpenAPILoaderOptions.putAuthHeader(String headerName,
String headerValue) |
OpenAPILoaderOptions |
OpenAPILoaderOptions.putAuthQueryParam(String queryParamName,
String queryParamValue) |
RouterBuilder |
RouterBuilder.rootHandler(Handler<RoutingContext> rootHandler)
Add global handler to be applied prior to
Router being generated. |
Operation |
Operation.routeToEventBus(String address)
Route an incoming request to this operation to a Web API Service
|
Operation |
Operation.routeToEventBus(String address,
DeliveryOptions options)
Route an incoming request to this operation to a Web API Service
|
RouterBuilder |
RouterBuilder.securityHandler(String securitySchemaName,
AuthenticationHandler handler)
Mount to paths that have to follow a security schema a security handler
|
RouterBuilder |
RouterBuilder.serviceExtraPayloadMapper(Function<RoutingContext,JsonObject> serviceExtraPayloadMapper)
When set, this function is called while creating the payload of
ServiceRequest |
RouterBuilderOptions |
RouterBuilderOptions.setContractEndpoint(String contractEndpoint)
Configures the endpoint where the contract is served.
|
RouterBuilderOptions |
RouterBuilderOptions.setMountNotImplementedHandler(boolean mountOperationsWithoutHandler)
If true, Router builder will automatically mount an handler that return HTTP 405/501 status code for each
operation where you didn't specify an handler.
|
RouterBuilderOptions |
RouterBuilderOptions.setMountResponseContentTypeHandler(boolean mountResponseContentTypeHandler)
If true, when required, the factory will mount a
ResponseContentTypeHandler |
RouterBuilderOptions |
RouterBuilderOptions.setOperationModelKey(String operationModelKey)
When set, an additional handler will be created to expose the operation model in the routing
context under the given key.
|
RouterBuilder |
RouterBuilder.setOptions(RouterBuilderOptions options)
Set options of router builder.
|
RouterBuilderOptions |
RouterBuilderOptions.setRequireSecurityHandlers(boolean requireSecurityHandlers)
If true, when you call
RouterBuilder.createRouter() ()} the factory will mount for every path
the required security handlers and, if a security handler is not defined, it throws an
RouterBuilderException |
RouterBuilderOptions |
RouterBuilderOptions.setRouteNamingStrategy(RouteNamingStrategy routeNamingStrategy)
The strategy to follow when naming the generated routes.
|
| Modifier and Type | Method and Description |
|---|---|
SessionStore |
SessionStore.init(Vertx vertx,
JsonObject options)
Initialize this store.
|
| Modifier and Type | Method and Description |
|---|---|
default SchemaRouter |
SchemaRouter.addJson(String uri,
JsonObject object)
Add one or more json documents including schemas on top or inner levels.
|
SchemaRouter |
SchemaRouter.addJson(URI uri,
JsonObject object)
Add one or more json documents including schemas on top or inner levels.
|
SchemaRouter |
SchemaRouter.addSchema(Schema schema,
JsonPointer... aliasScopes)
Add a parsed schema to this router.
|
SchemaRouter |
SchemaRouter.addSchemaAlias(Schema schema,
String alias)
Add an alias to a schema already registered in this router (this alias can be solved only from schema scope).
|
SchemaRouter |
SchemaRouter.addSchemaWithScope(Schema schema,
JsonPointer scope)
Add a parsed schema to this router.
|
SchemaRouterOptions |
SchemaRouterOptions.putAuthHeader(String headerName,
String headerValue)
Put an header to authenticate requests while loading an external schema
|
SchemaRouterOptions |
SchemaRouterOptions.putAuthQueryParam(String queryParamName,
String queryParamValue)
Put a query parameter to authenticate requests while loading an external schema
|
SchemaParser |
SchemaParser.withStringFormatValidator(String formatName,
Predicate<String> predicate)
Add a custom format validator
|
SchemaParser |
SchemaParser.withValidatorFactory(ValidatorFactory factory)
Add a
ValidatorFactory to this schema parser to support custom keywords |
| Modifier and Type | Method and Description |
|---|---|
TupleSchemaBuilder |
TupleSchemaBuilder.additionalItems(SchemaBuilder schemaBuilder) |
T |
SchemaBuilder.alias(String alias) |
NumberSchemaBuilder |
NumberSchemaBuilder.asInteger() |
T |
SchemaBuilder.defaultValue(Object defaultValue) |
T |
SchemaBuilder.fromJson(JsonObject object) |
T |
SchemaBuilder.id(JsonPointer id) |
TupleSchemaBuilder |
TupleSchemaBuilder.item(SchemaBuilder schemaBuilder) |
ArraySchemaBuilder |
ArraySchemaBuilder.items(SchemaBuilder schemaBuilder) |
T |
SchemaBuilder.nullable() |
T |
SchemaBuilder.type(SchemaType type) |
T |
SchemaBuilder.with(K... keywords) |
T |
SchemaBuilder.with(K keyword) |
T |
SchemaBuilder.withKeyword(String key,
Object value) |
| Modifier and Type | Method and Description |
|---|---|
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.
|
KafkaConsumer<K,V> |
KafkaConsumer.assignment(Handler<AsyncResult<Set<TopicPartition>>> handler)
Get the set of partitions currently assigned to this consumer.
|
KafkaConsumer<K,V> |
KafkaConsumer.batchHandler(Handler<KafkaConsumerRecords<K,V>> handler)
Set the handler to be used when batches of messages are fetched
from the Kafka server.
|
KafkaConsumer<K,V> |
KafkaConsumer.endHandler(Handler<Void> endHandler) |
KafkaConsumer<K,V> |
KafkaConsumer.exceptionHandler(Handler<Throwable> handler) |
KafkaConsumer<K,V> |
KafkaConsumer.handler(Handler<KafkaConsumerRecord<K,V>> handler) |
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.
|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsAssignedHandler(Handler<Set<TopicPartition>> handler)
Set the handler called when topic partitions are assigned to the consumer
|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsFor(String topic,
Handler<AsyncResult<List<PartitionInfo>>> handler)
Get metadata about the partitions for a given topic.
|
KafkaConsumer<K,V> |
KafkaConsumer.partitionsRevokedHandler(Handler<Set<TopicPartition>> handler)
Set the handler called when topic partitions are revoked to the consumer
|
KafkaConsumer<K,V> |
KafkaConsumer.pause() |
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.
|
KafkaConsumer<K,V> |
KafkaConsumer.pollTimeout(Duration timeout)
Sets the poll timeout for the underlying native Kafka Consumer.
|
KafkaConsumer<K,V> |
KafkaConsumer.resume() |
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.
|
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.
|
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.
|
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.
|
KafkaConsumer<K,V> |
KafkaConsumer.subscribe(Pattern pattern,
Handler<AsyncResult<Void>> completionHandler)
Subscribe to all topics matching specified pattern 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.
|
KafkaConsumer<K,V> |
KafkaConsumer.subscription(Handler<AsyncResult<Set<String>>> handler)
Get the current subscription.
|
KafkaConsumer<K,V> |
KafkaConsumer.unsubscribe(Handler<AsyncResult<Void>> completionHandler)
Unsubscribe from topics currently subscribed with subscribe.
|
| Modifier and Type | Method and Description |
|---|---|
KafkaProducer<K,V> |
KafkaProducer.abortTransaction(Handler<AsyncResult<Void>> handler)
Aborts the ongoing transaction.
|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(KafkaHeader header)
Add an header to this record.
|
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
Buffer value)
Like
KafkaProducerRecord.addHeader(KafkaHeader) but with a key/value pair |
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeader(String key,
String value)
Like
KafkaProducerRecord.addHeader(KafkaHeader) but with a key/value pair |
KafkaProducerRecord<K,V> |
KafkaProducerRecord.addHeaders(List<KafkaHeader> headers)
Add a list of headers to this record.
|
KafkaProducer<K,V> |
KafkaProducer.beginTransaction(Handler<AsyncResult<Void>> handler)
Starts a new kafka transaction.
|
KafkaProducer<K,V> |
KafkaProducer.commitTransaction(Handler<AsyncResult<Void>> handler)
Commits the ongoing transaction.
|
KafkaWriteStream<K,V> |
KafkaWriteStream.drainHandler(Handler<Void> handler) |
KafkaProducer<K,V> |
KafkaProducer.drainHandler(Handler<Void> handler) |
KafkaWriteStream<K,V> |
KafkaWriteStream.exceptionHandler(Handler<Throwable> handler) |
KafkaProducer<K,V> |
KafkaProducer.exceptionHandler(Handler<Throwable> handler) |
KafkaProducer<K,V> |
KafkaProducer.flush(Handler<AsyncResult<Void>> completionHandler)
Invoking this method makes all buffered records immediately available to write
|
KafkaProducer<K,V> |
KafkaProducer.initTransactions(Handler<AsyncResult<Void>> handler)
Initializes the underlying kafka transactional producer.
|
KafkaProducer<K,V> |
KafkaProducer.partitionsFor(String topic,
Handler<AsyncResult<List<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.setWriteQueueMaxSize(int i) |
KafkaProducer<K,V> |
KafkaProducer.setWriteQueueMaxSize(int i) |
| Modifier and Type | Method and Description |
|---|---|
MqttEndpoint |
MqttEndpoint.accept()
Like
MqttEndpoint.accept(boolean) with no session is present. |
MqttEndpoint |
MqttEndpoint.accept(boolean sessionPresent)
Sends the CONNACK message to the remote MQTT client with "connection accepted"
return code.
|
MqttEndpoint |
MqttEndpoint.autoKeepAlive(boolean isAutoKeepAlive)
Enable/disable auto keep alive (sending ping response)
|
MqttEndpoint |
MqttEndpoint.closeHandler(Handler<Void> handler)
Set a close handler.
|
MqttClient |
MqttClient.closeHandler(Handler<Void> closeHandler)
Set a handler that will be called when the connection with server is closed
|
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
|
MqttEndpoint |
MqttEndpoint.disconnectHandler(Handler<Void> handler)
Set a disconnect handler on the MQTT endpoint.
|
MqttServer |
MqttServer.endpointHandler(Handler<MqttEndpoint> handler)
Set the endpoint handler for the server.
|
MqttEndpoint |
MqttEndpoint.exceptionHandler(Handler<Throwable> handler)
Set an exception handler.
|
MqttServer |
MqttServer.exceptionHandler(Handler<Throwable> handler)
Set an exception handler for the server, that will be called when an error happens independantly of an
accepted
MqttEndpoint, like a rejected connection |
MqttClient |
MqttClient.exceptionHandler(Handler<Throwable> handler)
Set an exception handler for the client, that will be called when an error happens
in internal netty structures.
|
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.ping()
This method is needed by the client in order to avoid server closes the
connection due to the keep alive timeout if client has no messages to send
|
MqttEndpoint |
MqttEndpoint.pingHandler(Handler<Void> handler)
Set the pingreq handler on the MQTT endpoint.
|
MqttClient |
MqttClient.pingResponseHandler(Handler<Void> pingResponseHandler)
Sets handler which will be called after PINGRESP packet receiving
|
MqttEndpoint |
MqttEndpoint.pong()
Sends the PINGRESP message to the remote MQTT client
|
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
|
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,
int messageId,
Handler<AsyncResult<Integer>> publishSentHandler)
Sends the PUBLISH message to the remote MQTT server explicitly specifying the messageId
|
MqttEndpoint |
MqttEndpoint.publishAcknowledge(int publishMessageId)
Sends the PUBACK message to the remote MQTT client
|
MqttEndpoint |
MqttEndpoint.publishAcknowledgeHandler(Handler<Integer> handler)
Set the puback handler on the MQTT endpoint.
|
MqttEndpoint |
MqttEndpoint.publishAutoAck(boolean isPublishAutoAck)
Enable/disable publishing (in/out) auto acknowledge
|
MqttEndpoint |
MqttEndpoint.publishComplete(int publishMessageId)
Sends the PUBCOMP message to the remote MQTT client
|
MqttClient |
MqttClient.publishCompletionExpirationHandler(Handler<Integer> publishCompletionExpirationHandler)
Sets a handler which will be called when the client does not receive a PUBACK or
PUBREC/PUBCOMP for a message published using QoS 1 or 2 respectively.
|
MqttEndpoint |
MqttEndpoint.publishCompletionHandler(Handler<Integer> handler)
Set the pubcomp handler on the MQTT endpoint.
|
MqttClient |
MqttClient.publishCompletionHandler(Handler<Integer> publishCompletionHandler)
Sets a handler which will be called each time the publishing of a message has been completed.
|
MqttClient |
MqttClient.publishCompletionUnknownPacketIdHandler(Handler<Integer> publishCompletionPhantomHandler)
Sets a handler which will be called when the client receives a PUBACK/PUBREC/PUBCOMP with an unknown
packet ID.
|
MqttEndpoint |
MqttEndpoint.publishHandler(Handler<MqttPublishMessage> handler)
Set the publish handler on the MQTT endpoint.
|
MqttClient |
MqttClient.publishHandler(Handler<MqttPublishMessage> publishHandler)
Sets handler which will be called each time server publish something to client
|
MqttEndpoint |
MqttEndpoint.publishReceived(int publishMessageId)
Sends the PUBREC message to the remote MQTT client
|
MqttEndpoint |
MqttEndpoint.publishReceivedHandler(Handler<Integer> handler)
Set the pubrec handler on the MQTT endpoint.
|
MqttEndpoint |
MqttEndpoint.publishRelease(int publishMessageId)
Sends the PUBREL message to the remote MQTT client
|
MqttEndpoint |
MqttEndpoint.publishReleaseHandler(Handler<Integer> handler)
Set the pubrel handler on the MQTT endpoint.
|
MqttEndpoint |
MqttEndpoint.reject(io.netty.handler.codec.mqtt.MqttConnectReturnCode returnCode)
Sends the CONNACK message to the remote MQTT client rejecting the connection
request with specified return code.
|
MqttEndpoint |
MqttEndpoint.setClientIdentifier(String clientIdentifier)
Set client identifier if not provided by the remote MQTT client (zero-bytes)
|
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
|
MqttEndpoint |
MqttEndpoint.subscribeAcknowledge(int subscribeMessageId,
List<io.netty.handler.codec.mqtt.MqttQoS> grantedQoSLevels)
Sends the SUBACK message to the remote MQTT client
|
MqttClient |
MqttClient.subscribeCompletionHandler(Handler<MqttSubAckMessage> subscribeCompletionHandler)
Sets handler which will be called after SUBACK packet receiving
|
MqttEndpoint |
MqttEndpoint.subscribeHandler(Handler<MqttSubscribeMessage> handler)
Set a subscribe handler on the MQTT endpoint.
|
MqttClient |
MqttClient.unsubscribe(String topic,
Handler<AsyncResult<Integer>> unsubscribeSentHandler)
Unsubscribe from receiving messages on given topic
|
MqttEndpoint |
MqttEndpoint.unsubscribeAcknowledge(int unsubscribeMessageId)
Sends the UNSUBACK message to the remote MQTT client
|
MqttClient |
MqttClient.unsubscribeCompletionHandler(Handler<Integer> unsubscribeCompletionHandler)
Sets handler which will be called after UNSUBACK packet receiving
|
MqttEndpoint |
MqttEndpoint.unsubscribeHandler(Handler<MqttUnsubscribeMessage> handler)
Set a unsubscribe handler on the MQTT endpoint.
|
| Modifier and Type | Method and Description |
|---|---|
MSSQLConnection |
MSSQLConnection.closeHandler(Handler<Void> handler)
Set an handler called when the connection is closed.
|
MSSQLConnection |
MSSQLConnection.exceptionHandler(Handler<Throwable> handler)
Set an handler called with connection errors.
|
MSSQLConnection |
MSSQLConnection.prepare(String s,
Handler<AsyncResult<PreparedStatement>> handler)
Create a prepared statement using the given
sql string. |
| 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.
|
MySQLConnection |
MySQLConnection.closeHandler(Handler<Void> handler)
Set an handler called when the connection is closed.
|
MySQLConnection |
MySQLConnection.debug(Handler<AsyncResult<Void>> handler)
Send a DEBUG command to dump debug information to the server's stdout.
|
MySQLConnection |
MySQLConnection.exceptionHandler(Handler<Throwable> handler)
Set an handler called with connection errors.
|
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)
Create a prepared statement using the given
sql string. |
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.closeHandler(Handler<Void> handler)
Set an handler called when the connection is closed.
|
PgConnection |
PgConnection.exceptionHandler(Handler<Throwable> handler)
Set an handler called with connection errors.
|
PgConnection |
PgConnection.notificationHandler(Handler<PgNotification> handler)
Set an handler called when the connection receives notification on a channel.
|
PgConnection |
PgConnection.prepare(String sql,
Handler<AsyncResult<PreparedStatement>> handler)
Create a prepared statement using the given
sql string. |
| Modifier and Type | Method and Description |
|---|---|
PgSubscriber |
PgSubscriber.closeHandler(Handler<Void> handler)
Set an handler called when the subscriber is closed.
|
PgSubscriber |
PgSubscriber.connect(Handler<AsyncResult<Void>> handler)
Connect the subscriber to Postgres.
|
PgSubscriber |
PgSubscriber.reconnectPolicy(Function<Integer,Long> policy)
Set the reconnect policy that is executed when the subscriber is disconnected.
|
PgChannel |
PgChannel.subscribeHandler(Handler<Void> handler)
Set an handler called when the the channel get subscribed.
|
| Modifier and Type | Method and Description |
|---|---|
default RedisAPI |
RedisAPI.acl(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command acl.
|
default RedisAPI |
RedisAPI.append(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command append.
|
Request |
Request.arg(boolean arg)
Adds a boolean encoded to string
|
Request |
Request.arg(Buffer arg)
Adds a String key argument
|
default Request |
Request.arg(byte arg)
Adds a byte encoded to string
|
Request |
Request.arg(byte[] arg)
Adds a byte array
|
default Request |
Request.arg(double arg)
Adds a double encoded to string
|
default Request |
Request.arg(float arg)
Adds a float encoded to string
|
default Request |
Request.arg(int arg)
Adds a int encoded to string
|
default Request |
Request.arg(JsonArray arg)
Adds a JsonArray argument, the encoding will serialize the json as value0, value1, ...
|
default Request |
Request.arg(JsonObject arg)
Adds a JsonObject argument, the encoding will serialize the json as key0, value0, key1, value1, ...
|
Request |
Request.arg(long arg)
Adds a long encoded to string
|
default Request |
Request.arg(short arg)
Adds a short encoded to string
|
default Request |
Request.arg(String arg)
Adds a String argument using UTF8 character encoding
|
default Request |
Request.arg(String arg,
String enc)
Adds a String using a specific character encoding argument
|
default RedisAPI |
RedisAPI.asking(Handler<AsyncResult<Response>> handler)
Redis command asking.
|
default RedisAPI |
RedisAPI.auth(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command auth.
|
default RedisConnection |
RedisConnection.batch(List<Request> commands,
Handler<AsyncResult<List<Response>>> onSend)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
default Redis |
Redis.batch(List<Request> commands,
Handler<AsyncResult<List<Response>>> onSend)
Sends a list of commands in a single IO operation, this prevents any inter twinning to happen from other
client users.
|
default RedisAPI |
RedisAPI.bgrewriteaof(Handler<AsyncResult<Response>> handler)
Redis command bgrewriteaof.
|
default RedisAPI |
RedisAPI.bgsave(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bgsave.
|
default RedisAPI |
RedisAPI.bitcount(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bitcount.
|
default RedisAPI |
RedisAPI.bitfield(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bitfield.
|
default RedisAPI |
RedisAPI.bitfieldRo(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bitfieldRo.
|
default RedisAPI |
RedisAPI.bitop(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bitop.
|
default RedisAPI |
RedisAPI.bitpos(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bitpos.
|
default RedisAPI |
RedisAPI.blpop(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command blpop.
|
default RedisAPI |
RedisAPI.brpop(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command brpop.
|
default RedisAPI |
RedisAPI.brpoplpush(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command brpoplpush.
|
default RedisAPI |
RedisAPI.bzpopmax(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bzpopmax.
|
default RedisAPI |
RedisAPI.bzpopmin(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command bzpopmin.
|
default RedisAPI |
RedisAPI.client(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command client.
|
default RedisAPI |
RedisAPI.cluster(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command cluster.
|
default RedisAPI |
RedisAPI.command(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command command.
|
default RedisAPI |
RedisAPI.config(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command config.
|
default Redis |
Redis.connect(Handler<AsyncResult<RedisConnection>> handler)
Connects to the redis server.
|
default RedisAPI |
RedisAPI.dbsize(Handler<AsyncResult<Response>> handler)
Redis command dbsize.
|
default RedisAPI |
RedisAPI.debug(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command debug.
|
default RedisAPI |
RedisAPI.decr(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command decr.
|
default RedisAPI |
RedisAPI.decrby(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command decrby.
|
default RedisAPI |
RedisAPI.del(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command del.
|
default RedisAPI |
RedisAPI.discard(Handler<AsyncResult<Response>> handler)
Redis command discard.
|
default RedisAPI |
RedisAPI.dump(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command dump.
|
default RedisAPI |
RedisAPI.echo(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command echo.
|
RedisConnection |
RedisConnection.endHandler(Handler<Void> endHandler)
Set an end handler.
|
default RedisAPI |
RedisAPI.eval(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command eval.
|
default RedisAPI |
RedisAPI.evalsha(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command evalsha.
|
RedisConnection |
RedisConnection.exceptionHandler(Handler<Throwable> handler)
Set an exception handler on the read stream.
|
default RedisAPI |
RedisAPI.exec(Handler<AsyncResult<Response>> handler)
Redis command exec.
|
default RedisAPI |
RedisAPI.exists(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command exists.
|
default RedisAPI |
RedisAPI.expire(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command expire.
|
default RedisAPI |
RedisAPI.expireat(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command expireat.
|
RedisConnection |
RedisConnection.fetch(long amount)
Fetch the specified
amount of elements. |
default RedisAPI |
RedisAPI.flushall(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command flushall.
|
default RedisAPI |
RedisAPI.flushdb(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command flushdb.
|
default RedisAPI |
RedisAPI.geoadd(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command geoadd.
|
default RedisAPI |
RedisAPI.geodist(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command geodist.
|
default RedisAPI |
RedisAPI.geohash(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command geohash.
|
default RedisAPI |
RedisAPI.geopos(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command geopos.
|
default RedisAPI |
RedisAPI.georadius(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command georadius.
|
default RedisAPI |
RedisAPI.georadiusbymember(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command georadiusbymember.
|
default RedisAPI |
RedisAPI.georadiusbymemberRo(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command georadiusbymemberRo.
|
default RedisAPI |
RedisAPI.georadiusRo(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command georadiusRo.
|
default RedisAPI |
RedisAPI.get(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command get.
|
default RedisAPI |
RedisAPI.getbit(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command getbit.
|
default RedisAPI |
RedisAPI.getrange(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command getrange.
|
default RedisAPI |
RedisAPI.getset(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command getset.
|
RedisConnection |
RedisConnection.handler(Handler<Response> handler)
Set a data handler.
|
default RedisAPI |
RedisAPI.hdel(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command hdel.
|
default RedisAPI |
RedisAPI.hello(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command hello.
|
default RedisAPI |
RedisAPI.hexists(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command hexists.
|
default RedisAPI |
RedisAPI.hget(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command hget.
|
default RedisAPI |
RedisAPI.hgetall(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command hgetall.
|
default RedisAPI |
RedisAPI.hincrby(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command hincrby.
|
default RedisAPI |
RedisAPI.hincrbyfloat(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command hincrbyfloat.
|
default RedisAPI |
RedisAPI.hkeys(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command hkeys.
|
default RedisAPI |
RedisAPI.hlen(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command hlen.
|
default RedisAPI |
RedisAPI.hmget(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command hmget.
|
default RedisAPI |
RedisAPI.hmset(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command hmset.
|
default RedisAPI |
RedisAPI.host(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command host.
|
default RedisAPI |
RedisAPI.hscan(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command hscan.
|
default RedisAPI |
RedisAPI.hset(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command hset.
|
default RedisAPI |
RedisAPI.hsetnx(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command hsetnx.
|
default RedisAPI |
RedisAPI.hstrlen(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command hstrlen.
|
default RedisAPI |
RedisAPI.hvals(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command hvals.
|
default RedisAPI |
RedisAPI.incr(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command incr.
|
default RedisAPI |
RedisAPI.incrby(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command incrby.
|
default RedisAPI |
RedisAPI.incrbyfloat(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command incrbyfloat.
|
default RedisAPI |
RedisAPI.info(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command info.
|
default RedisAPI |
RedisAPI.keys(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command keys.
|
default RedisAPI |
RedisAPI.lastsave(Handler<AsyncResult<Response>> handler)
Redis command lastsave.
|
default RedisAPI |
RedisAPI.latency(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command latency.
|
default RedisAPI |
RedisAPI.lindex(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command lindex.
|
default RedisAPI |
RedisAPI.linsert(String arg0,
String arg1,
String arg2,
String arg3,
Handler<AsyncResult<Response>> handler)
Redis command linsert.
|
default RedisAPI |
RedisAPI.llen(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command llen.
|
default RedisAPI |
RedisAPI.lolwut(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command lolwut.
|
default RedisAPI |
RedisAPI.lpop(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command lpop.
|
default RedisAPI |
RedisAPI.lpush(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command lpush.
|
default RedisAPI |
RedisAPI.lpushx(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command lpushx.
|
default RedisAPI |
RedisAPI.lrange(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command lrange.
|
default RedisAPI |
RedisAPI.lrem(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command lrem.
|
default RedisAPI |
RedisAPI.lset(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command lset.
|
default RedisAPI |
RedisAPI.ltrim(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command ltrim.
|
default RedisAPI |
RedisAPI.memory(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command memory.
|
default RedisAPI |
RedisAPI.mget(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command mget.
|
default RedisAPI |
RedisAPI.migrate(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command migrate.
|
default RedisAPI |
RedisAPI.module(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command module.
|
default RedisAPI |
RedisAPI.monitor(Handler<AsyncResult<Response>> handler)
Redis command monitor.
|
default RedisAPI |
RedisAPI.move(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command move.
|
default RedisAPI |
RedisAPI.mset(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command mset.
|
default RedisAPI |
RedisAPI.msetnx(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command msetnx.
|
default RedisAPI |
RedisAPI.multi(Handler<AsyncResult<Response>> handler)
Redis command multi.
|
Request |
Request.nullArg()
Adds a
null encoded string. |
default RedisAPI |
RedisAPI.object(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command object.
|
RedisConnection |
RedisConnection.pause()
Pause the
ReadStream, it sets the buffer in fetch mode and clears the actual demand. |
default RedisAPI |
RedisAPI.persist(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command persist.
|
default RedisAPI |
RedisAPI.pexpire(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command pexpire.
|
default RedisAPI |
RedisAPI.pexpireat(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command pexpireat.
|
default RedisAPI |
RedisAPI.pfadd(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command pfadd.
|
default RedisAPI |
RedisAPI.pfcount(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command pfcount.
|
default RedisAPI |
RedisAPI.pfdebug(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command pfdebug.
|
default RedisAPI |
RedisAPI.pfmerge(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command pfmerge.
|
default RedisAPI |
RedisAPI.pfselftest(Handler<AsyncResult<Response>> handler)
Redis command pfselftest.
|
default RedisAPI |
RedisAPI.ping(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command ping.
|
default RedisAPI |
RedisAPI.post(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command post.
|
default RedisAPI |
RedisAPI.psetex(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command psetex.
|
default RedisAPI |
RedisAPI.psubscribe(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command psubscribe.
|
default RedisAPI |
RedisAPI.psync(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command psync.
|
default RedisAPI |
RedisAPI.pttl(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command pttl.
|
default RedisAPI |
RedisAPI.publish(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command publish.
|
default RedisAPI |
RedisAPI.pubsub(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command pubsub.
|
default RedisAPI |
RedisAPI.punsubscribe(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command punsubscribe.
|
default RedisAPI |
RedisAPI.randomkey(Handler<AsyncResult<Response>> handler)
Redis command randomkey.
|
default RedisAPI |
RedisAPI.readonly(Handler<AsyncResult<Response>> handler)
Redis command readonly.
|
default RedisAPI |
RedisAPI.readwrite(Handler<AsyncResult<Response>> handler)
Redis command readwrite.
|
default RedisAPI |
RedisAPI.rename(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command rename.
|
default RedisAPI |
RedisAPI.renamenx(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command renamenx.
|
default RedisAPI |
RedisAPI.replconf(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command replconf.
|
default RedisAPI |
RedisAPI.replicaof(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command replicaof.
|
default RedisAPI |
RedisAPI.restore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command restore.
|
default RedisAPI |
RedisAPI.restoreAsking(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command restoreAsking.
|
RedisConnection |
RedisConnection.resume()
Resume reading, and sets the buffer in
flowing mode. |
default RedisAPI |
RedisAPI.role(Handler<AsyncResult<Response>> handler)
Redis command role.
|
default RedisAPI |
RedisAPI.rpop(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command rpop.
|
default RedisAPI |
RedisAPI.rpoplpush(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command rpoplpush.
|
default RedisAPI |
RedisAPI.rpush(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command rpush.
|
default RedisAPI |
RedisAPI.rpushx(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command rpushx.
|
default RedisAPI |
RedisAPI.sadd(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sadd.
|
default RedisAPI |
RedisAPI.save(Handler<AsyncResult<Response>> handler)
Redis command save.
|
default RedisAPI |
RedisAPI.scan(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command scan.
|
default RedisAPI |
RedisAPI.scard(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command scard.
|
default RedisAPI |
RedisAPI.script(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command script.
|
default RedisAPI |
RedisAPI.sdiff(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sdiff.
|
default RedisAPI |
RedisAPI.sdiffstore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sdiffstore.
|
default RedisAPI |
RedisAPI.select(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command select.
|
default RedisConnection |
RedisConnection.send(Request command,
Handler<AsyncResult<Response>> onSend)
Send the given command to the redis server or cluster.
|
default Redis |
Redis.send(Request command,
Handler<AsyncResult<Response>> onSend)
Send the given command to the redis server or cluster.
|
default RedisAPI |
RedisAPI.set(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command set.
|
default RedisAPI |
RedisAPI.setbit(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command setbit.
|
default RedisAPI |
RedisAPI.setex(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command setex.
|
default RedisAPI |
RedisAPI.setnx(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command setnx.
|
default RedisAPI |
RedisAPI.setrange(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command setrange.
|
default RedisAPI |
RedisAPI.shutdown(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command shutdown.
|
default RedisAPI |
RedisAPI.sinter(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sinter.
|
default RedisAPI |
RedisAPI.sinterstore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sinterstore.
|
default RedisAPI |
RedisAPI.sismember(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command sismember.
|
default RedisAPI |
RedisAPI.slaveof(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command slaveof.
|
default RedisAPI |
RedisAPI.slowlog(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command slowlog.
|
default RedisAPI |
RedisAPI.smembers(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command smembers.
|
default RedisAPI |
RedisAPI.smove(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command smove.
|
default RedisAPI |
RedisAPI.sort(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sort.
|
default RedisAPI |
RedisAPI.spop(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command spop.
|
default RedisAPI |
RedisAPI.srandmember(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command srandmember.
|
default RedisAPI |
RedisAPI.srem(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command srem.
|
default RedisAPI |
RedisAPI.sscan(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sscan.
|
default RedisAPI |
RedisAPI.stralgo(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command stralgo.
|
default RedisAPI |
RedisAPI.strlen(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command strlen.
|
default RedisAPI |
RedisAPI.subscribe(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command subscribe.
|
default RedisAPI |
RedisAPI.substr(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command substr.
|
default RedisAPI |
RedisAPI.sunion(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sunion.
|
default RedisAPI |
RedisAPI.sunionstore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command sunionstore.
|
default RedisAPI |
RedisAPI.swapdb(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command swapdb.
|
default RedisAPI |
RedisAPI.sync(Handler<AsyncResult<Response>> handler)
Redis command sync.
|
default RedisAPI |
RedisAPI.time(Handler<AsyncResult<Response>> handler)
Redis command time.
|
default RedisAPI |
RedisAPI.touch(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command touch.
|
default RedisAPI |
RedisAPI.ttl(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command ttl.
|
default RedisAPI |
RedisAPI.type(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command type.
|
default RedisAPI |
RedisAPI.unlink(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command unlink.
|
default RedisAPI |
RedisAPI.unsubscribe(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command unsubscribe.
|
default RedisAPI |
RedisAPI.unwatch(Handler<AsyncResult<Response>> handler)
Redis command unwatch.
|
default RedisAPI |
RedisAPI.wait(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command wait.
|
default RedisAPI |
RedisAPI.watch(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command watch.
|
default RedisAPI |
RedisAPI.xack(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xack.
|
default RedisAPI |
RedisAPI.xadd(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xadd.
|
default RedisAPI |
RedisAPI.xclaim(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xclaim.
|
default RedisAPI |
RedisAPI.xdel(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xdel.
|
default RedisAPI |
RedisAPI.xgroup(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xgroup.
|
default RedisAPI |
RedisAPI.xinfo(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xinfo.
|
default RedisAPI |
RedisAPI.xlen(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command xlen.
|
default RedisAPI |
RedisAPI.xpending(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xpending.
|
default RedisAPI |
RedisAPI.xrange(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xrange.
|
default RedisAPI |
RedisAPI.xread(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xread.
|
default RedisAPI |
RedisAPI.xreadgroup(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xreadgroup.
|
default RedisAPI |
RedisAPI.xrevrange(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xrevrange.
|
default RedisAPI |
RedisAPI.xsetid(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command xsetid.
|
default RedisAPI |
RedisAPI.xtrim(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command xtrim.
|
default RedisAPI |
RedisAPI.zadd(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zadd.
|
default RedisAPI |
RedisAPI.zcard(String arg0,
Handler<AsyncResult<Response>> handler)
Redis command zcard.
|
default RedisAPI |
RedisAPI.zcount(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command zcount.
|
default RedisAPI |
RedisAPI.zincrby(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command zincrby.
|
default RedisAPI |
RedisAPI.zinterstore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zinterstore.
|
default RedisAPI |
RedisAPI.zlexcount(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command zlexcount.
|
default RedisAPI |
RedisAPI.zpopmax(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zpopmax.
|
default RedisAPI |
RedisAPI.zpopmin(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zpopmin.
|
default RedisAPI |
RedisAPI.zrange(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrange.
|
default RedisAPI |
RedisAPI.zrangebylex(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrangebylex.
|
default RedisAPI |
RedisAPI.zrangebyscore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrangebyscore.
|
default RedisAPI |
RedisAPI.zrank(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command zrank.
|
default RedisAPI |
RedisAPI.zrem(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrem.
|
default RedisAPI |
RedisAPI.zremrangebylex(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command zremrangebylex.
|
default RedisAPI |
RedisAPI.zremrangebyrank(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command zremrangebyrank.
|
default RedisAPI |
RedisAPI.zremrangebyscore(String arg0,
String arg1,
String arg2,
Handler<AsyncResult<Response>> handler)
Redis command zremrangebyscore.
|
default RedisAPI |
RedisAPI.zrevrange(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrevrange.
|
default RedisAPI |
RedisAPI.zrevrangebylex(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrevrangebylex.
|
default RedisAPI |
RedisAPI.zrevrangebyscore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zrevrangebyscore.
|
default RedisAPI |
RedisAPI.zrevrank(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command zrevrank.
|
default RedisAPI |
RedisAPI.zscan(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zscan.
|
default RedisAPI |
RedisAPI.zscore(String arg0,
String arg1,
Handler<AsyncResult<Response>> handler)
Redis command zscore.
|
default RedisAPI |
RedisAPI.zunionstore(List<String> args,
Handler<AsyncResult<Response>> handler)
Redis command zunionstore.
|
| Modifier and Type | Method and Description |
|---|---|
ServiceDiscovery |
ServiceDiscovery.registerServiceExporter(ServiceExporter exporter,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery bridge.
|
ServiceDiscovery |
ServiceDiscovery.registerServiceImporter(ServiceImporter importer,
JsonObject configuration,
Handler<AsyncResult<Void>> completionHandler)
Registers a discovery service importer.
|
| Modifier and Type | Method and Description |
|---|---|
default Tuple |
Tuple.addBoolean(Boolean value)
Add a boolean value at the end of the tuple.
|
default Tuple |
Tuple.addBuffer(Buffer value)
Add a buffer value at the end of the tuple.
|
default Tuple |
Tuple.addDouble(Double value)
Add a double value at the end of the tuple.
|
default Tuple |
Tuple.addFloat(Float value)
Add a float value at the end of the tuple.
|
default Tuple |
Tuple.addInteger(Integer value)
Add an integer value at the end of the tuple.
|
default Tuple |
Tuple.addJsonArray(JsonArray value)
Add a
JsonArray value at the end of the tuple. |
default Tuple |
Tuple.addJsonObject(JsonObject value)
Add a
JsonObject value at the end of the tuple. |
default Tuple |
Tuple.addLong(Long value)
Add a long value at the end of the tuple.
|
default Tuple |
Tuple.addShort(Short value)
Add a short value at the end of the tuple.
|
default Tuple |
Tuple.addString(String value)
Add a string value at the end of the tuple.
|
Tuple |
Tuple.addValue(Object value)
Add an object value at the end of the tuple.
|
SqlConnection |
SqlConnection.closeHandler(Handler<Void> handler)
Set an handler called when the connection is closed.
|
RowStream<T> |
RowStream.endHandler(Handler<Void> endHandler) |
RowStream<T> |
RowStream.exceptionHandler(Handler<Throwable> handler) |
SqlConnection |
SqlConnection.exceptionHandler(Handler<Throwable> handler)
Set an handler called with connection errors.
|
RowStream<T> |
RowStream.fetch(long l) |
RowStream<T> |
RowStream.handler(Handler<T> handler) |
RowStream<T> |
RowStream.pause() |
SqlConnection |
SqlConnection.prepare(String sql,
Handler<AsyncResult<PreparedStatement>> handler)
Create a prepared statement using the given
sql string. |
RowStream<T> |
RowStream.resume() |
Copyright © 2021. All rights reserved.