public interface AmqpConnection
AmqpConnection exceptionHandler(Handler<Throwable> handler)
handler - the exception handler.AmqpConnection close(Handler<AsyncResult<Void>> done)
done - the close handler notified when the connection is closed. May be null.AmqpConnection createReceiver(String address, Handler<AsyncResult<AmqpReceiver>> completionHandler)
address - The source address to attach the consumer to, must not be nullcompletionHandler - the handler called with the receiver. The receiver has been opened.Future<AmqpReceiver> createReceiver(String address)
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.Future<AmqpReceiver> createReceiver(String address, AmqpReceiverOptions receiverOptions)
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.Future<AmqpReceiver> createDynamicReceiver()
AmqpConnection createSender(String address, Handler<AsyncResult<AmqpSender>> completionHandler)
createAnonymousSender(Handler).address - The target address to attach to, must not be nullcompletionHandler - The handler called with the sender, once openedcreateAnonymousSender(Handler)Future<AmqpSender> createSender(String address)
AmqpConnection createSender(String address, AmqpSenderOptions options, Handler<AsyncResult<AmqpSender>> completionHandler)
createAnonymousSender(Handler).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 openedcreateAnonymousSender(Handler)Future<AmqpSender> createSender(String address, AmqpSenderOptions options)
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 openedFuture<AmqpSender> createAnonymousSender()
Copyright © 2019 Eclipse. All rights reserved.