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 |
---|---|
Completable |
close()
Closes the AMQP connection, i.e.
|
Single<AmqpSender> |
createAnonymousSender()
Creates an anonymous sender.
|
Single<AmqpReceiver> |
createDynamicReceiver()
Creates a dynamic receiver.
|
Single<AmqpReceiver> |
createReceiver(String address)
Creates a receiver used to consume messages from the given address.
|
Single<AmqpReceiver> |
createReceiver(String address,
AmqpReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given address.
|
Single<AmqpSender> |
createSender(String address)
Creates a sender used to send messages to the given address.
|
Single<AmqpSender> |
createSender(String address,
AmqpSenderOptions options)
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() |
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 Completable close()
public Completable rxClose()
public Single<AmqpReceiver> 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 Single<AmqpReceiver> 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 Single<AmqpReceiver> 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 Single<AmqpSender> createSender(String address)
createAnonymousSender()
.address
- The target address to attach to, must not be null
public Single<AmqpSender> rxCreateSender(String address)
createAnonymousSender()
.address
- The target address to attach to, must not be null
public Single<AmqpSender> createSender(String address, AmqpSenderOptions options)
createAnonymousSender()
.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()
.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> 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.