Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<AmqpConnection> |
__TYPE_ARG |
Constructor and Description |
---|
AmqpConnection(AmqpConnection delegate) |
AmqpConnection(Object delegate) |
Modifier and Type | Method and Description |
---|---|
AmqpConnection |
close()
Closes the AMQP connection, i.e.
|
AmqpConnection |
close(Handler<AsyncResult<Void>> done)
Closes the AMQP connection, i.e.
|
AmqpConnection |
createAnonymousSender()
Creates an anonymous sender.
|
AmqpConnection |
createAnonymousSender(Handler<AsyncResult<AmqpSender>> completionHandler)
Creates an anonymous sender.
|
AmqpConnection |
createDynamicReceiver()
Creates a dynamic receiver.
|
AmqpConnection |
createDynamicReceiver(Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a dynamic receiver.
|
AmqpConnection |
createReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
AmqpConnection |
createReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
AmqpConnection |
createReceiver(String address,
AmqpReceiverOptions receiverOptions,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consumer messages from the given address.
|
AmqpConnection |
createReceiver(String address,
Handler<AsyncResult<AmqpReceiver>> completionHandler)
Creates a receiver used to consume messages from the given address.
|
AmqpConnection |
createSender(String address)
Creates a sender used to send messages to the given address.
|
AmqpConnection |
createSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
AmqpConnection |
createSender(String address,
AmqpSenderOptions options,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
AmqpConnection |
createSender(String address,
Handler<AsyncResult<AmqpSender>> completionHandler)
Creates a sender used to send messages to the given address.
|
boolean |
equals(Object o) |
AmqpConnection |
exceptionHandler(Handler<Throwable> handler)
Registers a handler called on disconnection.
|
AmqpConnection |
getDelegate() |
int |
hashCode() |
boolean |
isDisconnected() |
static AmqpConnection |
newInstance(AmqpConnection arg) |
Single<Void> |
rxClose()
Closes the AMQP connection, i.e.
|
Single<AmqpSender> |
rxCreateAnonymousSender()
Creates an anonymous sender.
|
Single<AmqpReceiver> |
rxCreateDynamicReceiver()
Creates a dynamic receiver.
|
Single<AmqpReceiver> |
rxCreateReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
Single<AmqpReceiver> |
rxCreateReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Single<AmqpSender> |
rxCreateSender(String address)
Creates a sender used to send messages to the given address.
|
Single<AmqpSender> |
rxCreateSender(String address,
AmqpSenderOptions options)
Creates a sender used to send messages to the given address.
|
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<AmqpConnection> __TYPE_ARG
public AmqpConnection(AmqpConnection delegate)
public AmqpConnection(Object delegate)
public AmqpConnection getDelegate()
public AmqpConnection exceptionHandler(Handler<Throwable> handler)
handler
- the exception handler.public AmqpConnection close(Handler<AsyncResult<Void>> done)
done
- the close handler notified when the connection is closed. May be null
.public AmqpConnection close()
public Single<Void> rxClose()
public AmqpConnection createReceiver(String address, Handler<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 AmqpConnection createReceiver(String address)
address
- The source address to attach the consumer to, must not be null
public Single<AmqpReceiver> rxCreateReceiver(String address)
address
- The source address to attach the consumer to, must not be null
public AmqpConnection createReceiver(String address, AmqpReceiverOptions receiverOptions, Handler<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 AmqpConnection createReceiver(String address, AmqpReceiverOptions receiverOptions)
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.public Single<AmqpReceiver> rxCreateReceiver(String address, AmqpReceiverOptions receiverOptions)
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.public AmqpConnection createDynamicReceiver(Handler<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 AmqpConnection createDynamicReceiver()
completionHandler
,
using the AmqpReceiver.address()
method. this method is useful for request-reply to generate a unique
reply address.public 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, Handler<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 AmqpConnection createSender(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 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, AmqpSenderOptions options, Handler<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 AmqpConnection createSender(String address, 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 Single<AmqpSender> rxCreateSender(String address, 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(Handler<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 AmqpConnection createAnonymousSender()
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 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 boolean isDisconnected()
public static AmqpConnection newInstance(AmqpConnection arg)
Copyright © 2021 Eclipse. All rights reserved.