- close
AmqpConnection close(AsyncResultHandler!Void done)
Undocumented in source. Be warned that the author may not have intended to support it.
- createAnonymousSender
AmqpConnection createAnonymousSender(Handler!AmqpSender completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createDynamicReceiver
AmqpConnection createDynamicReceiver(Handler!AmqpReceiver completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
AmqpConnection createReceiver(string address, Handler!AmqpReceiver completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createReceiver
AmqpConnection createReceiver(string address, AmqpReceiverOptions receiverOptions, Handler!AmqpReceiver completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createSender
AmqpConnection createSender(string address, Handler!AmqpSender completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- createSender
AmqpConnection createSender(string address, AmqpSenderOptions options, Handler!AmqpSender completionHandler)
Undocumented in source. Be warned that the author may not have intended to support it.
- exceptionHandler
AmqpConnection exceptionHandler(Handler!Throwable handler)
Undocumented in source. Be warned that the author may not have intended to support it.
- isClosed
bool isClosed()
Undocumented in source. Be warned that the author may not have intended to support it.
- options
AmqpClientOptions options()
Undocumented in source. Be warned that the author may not have intended to support it.
- register
void register(AmqpSenderImpl sender)
Undocumented in source. Be warned that the author may not have intended to support it.
- register
void register(AmqpReceiverImpl receiver)
Undocumented in source. Be warned that the author may not have intended to support it.
- runOnContext
void runOnContext(Handler!Void action)
Undocumented in source. Be warned that the author may not have intended to support it.
- runWithTrampoline
void runWithTrampoline(Handler!Void action)
Undocumented in source. Be warned that the author may not have intended to support it.
- unregister
void unregister(AmqpSender sender)
Undocumented in source. Be warned that the author may not have intended to support it.
- unregister
void unregister(AmqpReceiver receiver)
Undocumented in source. Be warned that the author may not have intended to support it.
- unwrap
ProtonConnection unwrap()
Undocumented in source. Be warned that the author may not have intended to support it.
- isClosed
bool isClosed()
Undocumented in source.
- exceptionHandler
AmqpConnection exceptionHandler(Handler!Throwable handler)
Registers a handler called on disconnection.
- close
AmqpConnection close(AsyncResultHandler!Void done)
Closes the AMQP connection, i.e. allows the Close frame to be emitted.
- createReceiver
AmqpConnection createReceiver(string address, Handler!AmqpReceiver completionHandler)
Creates a receiver used to consume messages from the given address. The receiver has no handler and won't
start receiving messages until a handler is explicitly configured.
- createReceiver
AmqpConnection createReceiver(string address, AmqpReceiverOptions receiverOptions, Handler!AmqpReceiver completionHandler)
Creates a receiver used to consumer messages from the given address.
- createDynamicReceiver
AmqpConnection createDynamicReceiver(Handler!AmqpReceiver completionHandler)
Creates a dynamic receiver. The address is provided by the broker and is available in the {@code completionHandler},
using the {@link AmqpReceiver#address()} method. this method is useful for request-reply to generate a unique
reply address.
- createSender
AmqpConnection createSender(string address, Handler!AmqpSender completionHandler)
Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check
{@link #createAnonymousSender(Handler)}.
- createSender
AmqpConnection createSender(string address, AmqpSenderOptions options, Handler!AmqpSender completionHandler)
Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check
{@link #createAnonymousSender(Handler)}.
- createAnonymousSender
AmqpConnection createAnonymousSender(Handler!AmqpSender completionHandler)
Creates an anonymous sender.
<p>
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.