Package | Description |
---|---|
io.vertx.rxjava.amqp |
Modifier and Type | Field and Description |
---|---|
static TypeArg<AmqpReceiver> |
AmqpReceiver.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
AmqpReceiver |
AmqpReceiver.endHandler(io.vertx.core.Handler<Void> endHandler) |
AmqpReceiver |
AmqpReceiver.exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
AmqpReceiver |
AmqpReceiver.fetch(long amount) |
AmqpReceiver |
AmqpReceiver.handler(io.vertx.core.Handler<AmqpMessage> handler) |
static AmqpReceiver |
AmqpReceiver.newInstance(io.vertx.amqp.AmqpReceiver arg) |
AmqpReceiver |
AmqpReceiver.pause() |
AmqpReceiver |
AmqpReceiver.resume() |
Modifier and Type | Method and Description |
---|---|
rx.Single<AmqpReceiver> |
AmqpConnection.rxCreateDynamicReceiver()
Creates a dynamic receiver.
|
rx.Single<AmqpReceiver> |
AmqpConnection.rxCreateReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
rx.Single<AmqpReceiver> |
AmqpClient.rxCreateReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
rx.Single<AmqpReceiver> |
AmqpConnection.rxCreateReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
rx.Single<AmqpReceiver> |
AmqpClient.rxCreateReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
rx.Single<AmqpReceiver> |
AmqpConnection.rxCreateReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<AmqpMessage> messageHandler)
Deprecated.
|
rx.Single<AmqpReceiver> |
AmqpClient.rxCreateReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<AmqpMessage> messageHandler)
Deprecated.
|
rx.Single<AmqpReceiver> |
AmqpConnection.rxCreateReceiver(String address,
io.vertx.core.Handler<AmqpMessage> messageHandler)
Deprecated.
|
rx.Single<AmqpReceiver> |
AmqpClient.rxCreateReceiver(String address,
io.vertx.core.Handler<AmqpMessage> messageHandler)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
AmqpConnection |
AmqpConnection.createDynamicReceiver(io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Creates a dynamic receiver.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<AmqpMessage> messageHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Deprecated.
|
AmqpClient |
AmqpClient.createReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<AmqpMessage> messageHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Deprecated.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpClient |
AmqpClient.createReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
io.vertx.core.Handler<AmqpMessage> messageHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Deprecated.
|
AmqpClient |
AmqpClient.createReceiver(String address,
io.vertx.core.Handler<AmqpMessage> messageHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Deprecated.
|
AmqpConnection |
AmqpConnection.createReceiver(String address,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpClient |
AmqpClient.createReceiver(String address,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
Copyright © 2019 Eclipse. All rights reserved.