Package | Description |
---|---|
io.vertx.amqp | |
io.vertx.reactivex.amqp | |
io.vertx.rxjava.amqp |
Modifier and Type | Method and Description |
---|---|
AmqpReceiverOptions |
AmqpReceiverOptions.addCapability(String capability)
Adds a capability to be set on the receiver source terminus.
|
AmqpReceiverOptions |
AmqpReceiverOptions.setAutoAcknowledgement(boolean auto)
Sets the auto-acknowledgement.
|
AmqpReceiverOptions |
AmqpReceiverOptions.setCapabilities(List<String> capabilities)
Sets the list of capabilities to be set on the receiver source terminus.
|
AmqpReceiverOptions |
AmqpReceiverOptions.setDurable(boolean durable)
Sets the durability.
|
AmqpReceiverOptions |
AmqpReceiverOptions.setDynamic(boolean dynamic)
Sets whether the Source terminus to be used should specify it is 'dynamic',
requesting the peer creates a node and names it with a generated address.
|
AmqpReceiverOptions |
AmqpReceiverOptions.setLinkName(String linkName) |
AmqpReceiverOptions |
AmqpReceiverOptions.setMaxBufferedMessages(int maxBufferSize)
Sets the max buffered messages.
|
AmqpReceiverOptions |
AmqpReceiverOptions.setQos(String qos)
Sets the local QOS config.
|
Modifier and Type | Method and Description |
---|---|
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.
|
static void |
AmqpReceiverOptionsConverter.fromJson(Iterable<Map.Entry<String,Object>> json,
AmqpReceiverOptions obj) |
static void |
AmqpReceiverOptionsConverter.toJson(AmqpReceiverOptions obj,
JsonObject json) |
static void |
AmqpReceiverOptionsConverter.toJson(AmqpReceiverOptions obj,
Map<String,Object> json) |
Constructor and Description |
---|
AmqpReceiverOptions(AmqpReceiverOptions other) |
Modifier and Type | Method and Description |
---|---|
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.
|
Single<AmqpReceiver> |
AmqpConnection.rxCreateReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Single<AmqpReceiver> |
AmqpClient.rxCreateReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Single<AmqpReceiver> |
AmqpConnection.rxCreateReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Single<AmqpReceiver> |
AmqpClient.rxCreateReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Copyright © 2023 Eclipse. All rights reserved.