Class AmqpConnection

Closes the AMQP connection, i.e. allows the Close frame to be emitted.

Closes the AMQP connection, i.e. allows the Close frame to be emitted.

Creates an anonymous sender.

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.

Creates an anonymous sender.

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.

Creates a dynamic receiver. The address is provided by the broker and is available in the completionHandler, using the {@link AmqpReceiver#address} method. this method is useful for request-reply to generate a unique reply address.

Creates a dynamic receiver. The address is provided by the broker and is available in the completionHandler, using the {@link AmqpReceiver#address} method. this method is useful for request-reply to generate a unique reply address.

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.

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.

Creates a receiver used to consumer messages from the given address.

Creates a receiver used to consumer messages from the given address.

Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check {@link AmqpConnection#createAnonymousSender}.

Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check {@link AmqpConnection#createAnonymousSender}.

Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check {@link AmqpConnection#createAnonymousSender}.

Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check {@link AmqpConnection#createAnonymousSender}.

Registers a handler called on disconnection.