public class AmqpConnection extends Object
original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static TypeArg<AmqpConnection> |
__TYPE_ARG |
Constructor and Description |
---|
AmqpConnection(io.vertx.amqp.AmqpConnection delegate) |
Modifier and Type | Method and Description |
---|---|
AmqpConnection |
close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> done)
Closes the AMQP connection, i.e.
|
AmqpConnection |
createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpSender>> completionHandler)
Creates an anonymous sender.
|
AmqpConnection |
createDynamicReceiver(io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Creates a dynamic receiver.
|
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.
|
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.
|
AmqpConnection |
createReceiver(String address,
io.vertx.core.Handler<AmqpMessage> messageHandler,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
Deprecated.
|
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.
|
AmqpConnection |
createSender(String address,
io.vertx.amqp.AmqpSenderOptions options,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpConnection |
createSender(String address,
io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
boolean |
equals(Object o) |
AmqpConnection |
exceptionHandler(io.vertx.core.Handler<Throwable> handler)
Registers a handler called on disconnection.
|
io.vertx.amqp.AmqpConnection |
getDelegate() |
int |
hashCode() |
static AmqpConnection |
newInstance(io.vertx.amqp.AmqpConnection arg) |
rx.Single<Void> |
rxClose()
Closes the AMQP connection, i.e.
|
rx.Single<AmqpSender> |
rxCreateAnonymousSender()
Creates an anonymous sender.
|
rx.Single<AmqpReceiver> |
rxCreateDynamicReceiver()
Creates a dynamic receiver.
|
rx.Single<AmqpReceiver> |
rxCreateReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
rx.Single<AmqpReceiver> |
rxCreateReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
rx.Single<AmqpReceiver> |
rxCreateReceiver(String address,
io.vertx.amqp.AmqpReceiverOptions receiverOptions,
io.vertx.core.Handler<AmqpMessage> messageHandler)
Deprecated.
|
rx.Single<AmqpReceiver> |
rxCreateReceiver(String address,
io.vertx.core.Handler<AmqpMessage> messageHandler)
Deprecated.
|
rx.Single<AmqpSender> |
rxCreateSender(String address)
Creates a sender used to send messages to the given address.
|
rx.Single<AmqpSender> |
rxCreateSender(String address,
io.vertx.amqp.AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
String |
toString() |
public static final TypeArg<AmqpConnection> __TYPE_ARG
public io.vertx.amqp.AmqpConnection getDelegate()
public AmqpConnection exceptionHandler(io.vertx.core.Handler<Throwable> handler)
handler
- the exception handler.public AmqpConnection close(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> done)
done
- the close handler notified when the connection is closed. May be null
.public rx.Single<Void> rxClose()
public AmqpConnection createReceiver(String address, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
address
- The source address to attach the consumer to, must not be null
completionHandler
- the handler called with the receiver. The receiver has been opened.public rx.Single<AmqpReceiver> rxCreateReceiver(String address)
address
- The source address to attach the consumer to, must not be null
@Deprecated public AmqpConnection createReceiver(String address, io.vertx.core.Handler<AmqpMessage> messageHandler, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
address
- The source address to attach the consumer to, must not be null
messageHandler
- The message handler, must not be null
completionHandler
- the handler called with the receiver that has been opened. Note that the messageHandler
can be called before the completionHandler
if messages are awaiting delivery.@Deprecated public rx.Single<AmqpReceiver> rxCreateReceiver(String address, io.vertx.core.Handler<AmqpMessage> messageHandler)
address
- The source address to attach the consumer to, must not be null
messageHandler
- The message handler, must not be null
@Deprecated public 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)
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.messageHandler
- The message handler, must not be null
completionHandler
- The handler called with the receiver, once opened. Note that the messageHandler
can be called before the completionHandler
if messages are awaiting delivery.@Deprecated public rx.Single<AmqpReceiver> rxCreateReceiver(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions, io.vertx.core.Handler<AmqpMessage> messageHandler)
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.messageHandler
- The message handler, must not be null
public AmqpConnection createReceiver(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.completionHandler
- The handler called with the receiver, once opened. Note that the messageHandler
can be called before the completionHandler
if messages are awaiting delivery.public rx.Single<AmqpReceiver> rxCreateReceiver(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions)
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.public AmqpConnection createDynamicReceiver(io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpReceiver>> completionHandler)
completionHandler
,
using the AmqpReceiver.address()
method. this method is useful for request-reply to generate a unique
reply address.completionHandler
- the completion handler, called when the receiver has been created and opened.public rx.Single<AmqpReceiver> rxCreateDynamicReceiver()
completionHandler
,
using the AmqpReceiver.address()
method. this method is useful for request-reply to generate a unique
reply address.public AmqpConnection createSender(String address, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpSender>> completionHandler)
createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.amqp.AmqpSender>>)
.address
- The target address to attach to, must not be null
completionHandler
- The handler called with the sender, once openedpublic rx.Single<AmqpSender> rxCreateSender(String address)
createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.amqp.AmqpSender>>)
.address
- The target address to attach to, must not be null
public AmqpConnection createSender(String address, io.vertx.amqp.AmqpSenderOptions options, io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpSender>> completionHandler)
createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.amqp.AmqpSender>>)
.address
- The target address to attach to, allowed to be null
if the options
configures the sender to be attached to a dynamic address (provided by the broker).options
- The AMQP sender optionscompletionHandler
- The handler called with the sender, once openedpublic rx.Single<AmqpSender> rxCreateSender(String address, io.vertx.amqp.AmqpSenderOptions options)
createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<io.vertx.rxjava.amqp.AmqpSender>>)
.address
- The target address to attach to, allowed to be null
if the options
configures the sender to be attached to a dynamic address (provided by the broker).options
- The AMQP sender optionspublic AmqpConnection createAnonymousSender(io.vertx.core.Handler<io.vertx.core.AsyncResult<AmqpSender>> completionHandler)
Unlike "regular" sender, this sender is not associated to a specific address, and each message sent must provide an address. This method can be used in request-reply scenarios where you create a sender to send the reply, but you don't know the address, as the reply address is passed into the message you are going to receive.
completionHandler
- The handler called with the created sender, once openedpublic rx.Single<AmqpSender> rxCreateAnonymousSender()
Unlike "regular" sender, this sender is not associated to a specific address, and each message sent must provide an address. This method can be used in request-reply scenarios where you create a sender to send the reply, but you don't know the address, as the reply address is passed into the message you are going to receive.
public static AmqpConnection newInstance(io.vertx.amqp.AmqpConnection arg)
Copyright © 2019 Eclipse. All rights reserved.