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.
|
Future<Void> |
closeFuture() |
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) |
Completable |
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() |
io.vertx.proton.ProtonConnection |
unwrap() |
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 Completable 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.reactivex.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.reactivex.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.reactivex.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.reactivex.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.reactivex.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.reactivex.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 Future<Void> closeFuture()
public io.vertx.proton.ProtonConnection unwrap()
public static AmqpConnection newInstance(AmqpConnection arg)
Copyright © 2022 Eclipse. All rights reserved.