AmqpConnection

Once connected to the broker or router, you get a connection. This connection is automatically opened.

interface AmqpConnection {

bool isClosed();

AmqpConnection exceptionHandler(Handler!Throwable handler);

AmqpConnection close(AsyncResultHandler!Void done);

AmqpConnection createReceiver(string address, Handler!AmqpReceiver completionHandler);

AmqpConnection createReceiver(string address, AmqpReceiverOptions receiverOptions, Handler!AmqpReceiver completionHandler);

AmqpConnection createDynamicReceiver(Handler!AmqpReceiver completionHandler);

AmqpConnection createSender(string address, Handler!AmqpSender completionHandler);

AmqpConnection createSender(string address, AmqpSenderOptions options, Handler!AmqpSender completionHandler);

AmqpConnection createAnonymousSender(Handler!AmqpSender completionHandler);

}

Members

Functions

close AmqpConnection close(AsyncResultHandler!Void done): Closes the AMQP connection, i.e. allows the Close frame to be emitted.
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.
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.
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.
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)}.
exceptionHandler AmqpConnection exceptionHandler(Handler!Throwable handler): Registers a handler called on disconnection.
isClosed bool isClosed(): Undocumented in source.

AmqpConnection

Members

Functions

Meta

Source