| Package | Description | 
|---|---|
| io.vertx.amqp | |
| io.vertx.reactivex.amqp | |
| io.vertx.rxjava.amqp | |
| io.vertx.rxjava3.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.setNoLocal(boolean noLocal)
Sets whether this receiver should not receive messages that were sent using the same underlying connection. 
 | 
AmqpReceiverOptions | 
AmqpReceiverOptions.setQos(String qos)
Sets the local QOS config. 
 | 
AmqpReceiverOptions | 
AmqpReceiverOptions.setSelector(String selector)
Sets a message selector string. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
Future<AmqpReceiver> | 
AmqpConnection.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
Like  
AmqpConnection.createReceiver(String, AmqpReceiverOptions, Handler) but returns a Future of the asynchronous result | 
Future<AmqpReceiver> | 
AmqpClient.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
Like  
AmqpClient.createReceiver(String, AmqpReceiverOptions, Handler) but returns a Future of the asynchronous result | 
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)
Creates a receiver used to consumer messages from the given address. 
 | 
AmqpClient | 
AmqpClient.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address. 
 | 
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)
Creates a receiver used to consumer messages from the given address. 
 | 
AmqpClient | 
AmqpClient.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address. 
 | 
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 | 
|---|---|
Single<AmqpReceiver> | 
AmqpConnection.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address. 
 | 
Single<AmqpReceiver> | 
AmqpClient.createReceiver(String address,
              AmqpReceiverOptions receiverOptions)
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 © 2024 Eclipse. All rights reserved.