Package | Description |
---|---|
io.vertx.amqp | |
io.vertx.reactivex.amqp | |
io.vertx.rxjava.amqp |
Modifier and Type | Method and Description |
---|---|
AmqpSenderOptions |
AmqpSenderOptions.addCapability(String capability)
Adds a capability to be set on the sender target terminus.
|
AmqpSenderOptions |
AmqpSenderOptions.setAutoDrained(boolean autoDrained)
Sets whether the link is automatically marked drained after the send queue drain handler callback
returns if the receiving peer requested that credit be drained.
|
AmqpSenderOptions |
AmqpSenderOptions.setCapabilities(List<String> capabilities)
Sets the list of capabilities to be set on the sender target terminus.
|
AmqpSenderOptions |
AmqpSenderOptions.setDynamic(boolean dynamic)
Sets whether the Target terminus to be used should specify it is 'dynamic',
requesting the peer creates a node and names it with a generated address.
|
AmqpSenderOptions |
AmqpSenderOptions.setLinkName(String linkName) |
Modifier and Type | Method and Description |
---|---|
Future<AmqpSender> |
AmqpConnection.createSender(String address,
AmqpSenderOptions options)
Like
AmqpConnection.createSender(String, AmqpSenderOptions, Handler) but returns a Future of the asynchronous result |
Future<AmqpSender> |
AmqpClient.createSender(String address,
AmqpSenderOptions options)
Like
AmqpClient.createSender(String, AmqpSenderOptions, Handler) but returns a Future of the asynchronous result |
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.
|
static void |
AmqpSenderOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
AmqpSenderOptions obj) |
static void |
AmqpSenderOptionsConverter.toJson(AmqpSenderOptions obj,
JsonObject json) |
static void |
AmqpSenderOptionsConverter.toJson(AmqpSenderOptions obj,
Map<String,Object> json) |
Constructor and Description |
---|
AmqpSenderOptions(AmqpSenderOptions other) |
Modifier and Type | Method and Description |
---|---|
AmqpConnection |
AmqpConnection.createSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
AmqpClient |
AmqpClient.createSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to 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.
|
Single<AmqpSender> |
AmqpConnection.rxCreateSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
Single<AmqpSender> |
AmqpClient.rxCreateSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
Modifier and Type | Method and Description |
---|---|
AmqpConnection |
AmqpConnection.createSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
AmqpClient |
AmqpClient.createSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to 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.
|
Single<AmqpSender> |
AmqpConnection.rxCreateSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
Single<AmqpSender> |
AmqpClient.rxCreateSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
Copyright © 2021 Eclipse. All rights reserved.