| Package | Description |
|---|---|
| io.vertx.amqp | |
| io.vertx.amqp.impl | |
| io.vertx.reactivex.amqp | |
| io.vertx.rxjava.amqp |
| Modifier and Type | Method and Description |
|---|---|
AmqpReceiver |
AmqpReceiver.endHandler(Handler<Void> endHandler) |
AmqpReceiver |
AmqpReceiver.exceptionHandler(Handler<Throwable> handler) |
AmqpReceiver |
AmqpReceiver.fetch(long amount) |
AmqpReceiver |
AmqpReceiver.handler(Handler<AmqpMessage> handler) |
AmqpReceiver |
AmqpReceiver.pause() |
AmqpReceiver |
AmqpReceiver.resume() |
| Modifier and Type | Method and Description |
|---|---|
Future<AmqpReceiver> |
AmqpConnection.createDynamicReceiver()
Like
AmqpConnection.createDynamicReceiver(Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpConnection.createReceiver(String address)
Like
AmqpConnection.createReceiver(String, Handler) but returns a Future of the asynchronous result |
Future<AmqpReceiver> |
AmqpClient.createReceiver(String address)
Like
AmqpClient.createReceiver(String, Handler) but returns a Future of the asynchronous result |
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 |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AmqpReceiverImpl |
| Modifier and Type | Method and Description |
|---|---|
AmqpReceiver |
AmqpReceiverImpl.exceptionHandler(Handler<Throwable> handler) |
AmqpReceiver |
AmqpReceiverImpl.handler(Handler<AmqpMessage> handler) |
| Modifier and Type | Method and Description |
|---|---|
Future<AmqpReceiver> |
AmqpConnectionImpl.createDynamicReceiver() |
Future<AmqpReceiver> |
AmqpConnectionImpl.createReceiver(String address) |
Future<AmqpReceiver> |
AmqpClientImpl.createReceiver(String address) |
Future<AmqpReceiver> |
AmqpConnectionImpl.createReceiver(String address,
AmqpReceiverOptions receiverOptions) |
Future<AmqpReceiver> |
AmqpClientImpl.createReceiver(String address,
AmqpReceiverOptions receiverOptions) |
| Modifier and Type | Method and Description |
|---|---|
AmqpConnection |
AmqpConnectionImpl.createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>> completionHandler) |
AmqpConnection |
AmqpConnectionImpl.createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler) |
AmqpClient |
AmqpClientImpl.createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler) |
AmqpConnection |
AmqpConnectionImpl.createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler) |
AmqpClient |
AmqpClientImpl.createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler) |
| Modifier and Type | Method and Description |
|---|---|
AmqpReceiver |
AmqpReceiver.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static AmqpReceiver |
AmqpReceiver.newInstance(AmqpReceiver arg) |
| Constructor and Description |
|---|
AmqpReceiver(AmqpReceiver delegate) |
| Modifier and Type | Method and Description |
|---|---|
AmqpReceiver |
AmqpReceiver.getDelegate() |
| Modifier and Type | Method and Description |
|---|---|
static AmqpReceiver |
AmqpReceiver.newInstance(AmqpReceiver arg) |
| Constructor and Description |
|---|
AmqpReceiver(AmqpReceiver delegate) |
Copyright © 2021. All rights reserved.