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.
|
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.