Package io.vertx.mutiny.amqp

Class AmqpConnection

java.lang.Object
io.vertx.mutiny.amqp.AmqpConnection
All Implemented Interfaces:
MutinyDelegate
public class AmqpConnection extends Object implements MutinyDelegate
Once connected to the broker or router, you get a connection. This connection is automatically opened.

NOTE: This class has been automatically generated from the original non Mutiny-ified interface using Vert.x codegen.

  • Field Details

  • Constructor Details

    • AmqpConnection

      public AmqpConnection(io.vertx.amqp.AmqpConnection delegate)

    • AmqpConnection

      public AmqpConnection(Object delegate)

  • Method Details

    • getDelegate

      public io.vertx.amqp.AmqpConnection getDelegate()
      Specified by:
      getDelegate in interface MutinyDelegate
      Returns:
      the delegate used by this Mutiny object of generated type

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • exceptionHandler

      public AmqpConnection exceptionHandler(Consumer<Throwable> handler)
      Parameters:
      handler - the exception handler.
      Returns:

    • close

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> close()
      Closes the AMQP connection, i.e. allows the Close frame to be emitted.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • closeAndAwait

      public Void closeAndAwait()
      Blocking variant of close().

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      the Void instance produced by the operation.

    • closeAndForget

      public AmqpConnection closeAndForget()
      Variant of close() that ignores the result of the operation.

      This method subscribes on the result of close(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from close() but you don't need to compose it with other operations.

      Returns:
      the instance of AmqpConnection to chain method calls.

    • createReceiver

      @CheckReturnValue public io.smallrye.mutiny.Uni<AmqpReceiver> createReceiver(String 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.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      address - The source address to attach the consumer to, must not be null
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • createReceiverAndAwait

      public AmqpReceiver createReceiverAndAwait(String address)
      Blocking variant of createReceiver(String).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      address - The source address to attach the consumer to, must not be null
      Returns:
      the AmqpReceiver instance produced by the operation.

    • createReceiverAndForget

      public AmqpConnection createReceiverAndForget(String address)
      Variant of createReceiver(String) that ignores the result of the operation.

      This method subscribes on the result of createReceiver(String), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from createReceiver(String) but you don't need to compose it with other operations.

      Parameters:
      address - The source address to attach the consumer to, must not be null
      Returns:
      the instance of AmqpConnection to chain method calls.

    • createReceiver

      @CheckReturnValue public io.smallrye.mutiny.Uni<AmqpReceiver> createReceiver(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions)
      Creates a receiver used to consumer messages from the given address.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      address - The source address to attach the consumer to.
      receiverOptions - The options for this receiver.
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • createReceiverAndAwait

      public AmqpReceiver createReceiverAndAwait(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions)
      Blocking variant of createReceiver(String,AmqpReceiverOptions).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      address - The source address to attach the consumer to.
      receiverOptions - The options for this receiver.
      Returns:
      the AmqpReceiver instance produced by the operation.

    • createReceiverAndForget

      public AmqpConnection createReceiverAndForget(String address, io.vertx.amqp.AmqpReceiverOptions receiverOptions)
      Variant of createReceiver(String,AmqpReceiverOptions) that ignores the result of the operation.

      This method subscribes on the result of createReceiver(String,AmqpReceiverOptions), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from createReceiver(String,AmqpReceiverOptions) but you don't need to compose it with other operations.

      Parameters:
      address - The source address to attach the consumer to.
      receiverOptions - The options for this receiver.
      Returns:
      the instance of AmqpConnection to chain method calls.

    • createDynamicReceiver

      @CheckReturnValue public io.smallrye.mutiny.Uni<AmqpReceiver> createDynamicReceiver()
      Creates a dynamic receiver. The address is provided by the broker and is available in the completionHandler, using the AmqpReceiver.address() method. this method is useful for request-reply to generate a unique reply address.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • createDynamicReceiverAndAwait

      public AmqpReceiver createDynamicReceiverAndAwait()
      Blocking variant of createDynamicReceiver().

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      the AmqpReceiver instance produced by the operation.

    • createDynamicReceiverAndForget

      public AmqpConnection createDynamicReceiverAndForget()
      Variant of createDynamicReceiver() that ignores the result of the operation.

      This method subscribes on the result of createDynamicReceiver(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from createDynamicReceiver() but you don't need to compose it with other operations.

      Returns:
      the instance of AmqpConnection to chain method calls.

    • createSender

      @CheckReturnValue public io.smallrye.mutiny.Uni<AmqpSender> createSender(String address)
      Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      address - The target address to attach to, must not be null
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • createSenderAndAwait

      public AmqpSender createSenderAndAwait(String address)
      Blocking variant of createSender(String).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      address - The target address to attach to, must not be null
      Returns:
      the AmqpSender instance produced by the operation.

    • createSenderAndForget

      public AmqpConnection createSenderAndForget(String address)
      Variant of createSender(String) that ignores the result of the operation.

      This method subscribes on the result of createSender(String), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from createSender(String) but you don't need to compose it with other operations.

      Parameters:
      address - The target address to attach to, must not be null
      Returns:
      the instance of AmqpConnection to chain method calls.

    • createSender

      @CheckReturnValue public io.smallrye.mutiny.Uni<AmqpSender> createSender(String address, io.vertx.amqp.AmqpSenderOptions options)
      Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Parameters:
      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 options
      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • createSenderAndAwait

      public AmqpSender createSenderAndAwait(String address, io.vertx.amqp.AmqpSenderOptions options)
      Blocking variant of createSender(String,AmqpSenderOptions).

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Parameters:
      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 options
      Returns:
      the AmqpSender instance produced by the operation.

    • createSenderAndForget

      public AmqpConnection createSenderAndForget(String address, io.vertx.amqp.AmqpSenderOptions options)
      Variant of createSender(String,AmqpSenderOptions) that ignores the result of the operation.

      This method subscribes on the result of createSender(String,AmqpSenderOptions), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from createSender(String,AmqpSenderOptions) but you don't need to compose it with other operations.

      Parameters:
      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 options
      Returns:
      the instance of AmqpConnection to chain method calls.

    • createAnonymousSender

      @CheckReturnValue public io.smallrye.mutiny.Uni<AmqpSender> createAnonymousSender()
      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.

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • createAnonymousSenderAndAwait

      public AmqpSender createAnonymousSenderAndAwait()
      Blocking variant of createAnonymousSender().

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      the AmqpSender instance produced by the operation.

    • createAnonymousSenderAndForget

      public AmqpConnection createAnonymousSenderAndForget()
      Variant of createAnonymousSender() that ignores the result of the operation.

      This method subscribes on the result of createAnonymousSender(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from createAnonymousSender() but you don't need to compose it with other operations.

      Returns:
      the instance of AmqpConnection to chain method calls.

    • isDisconnected

      public boolean isDisconnected()
      Returns:
      whether the connection has been disconnected.

    • closeFuture

      @CheckReturnValue public io.smallrye.mutiny.Uni<Void> closeFuture()

      Unlike the bare Vert.x variant, this method returns a Uni. Don't forget to subscribe on it to trigger the operation.

      Returns:
      the uni firing the result of the operation when completed, or a failure if the operation failed.

    • closeFutureAndAwait

      public Void closeFutureAndAwait()
      Blocking variant of closeFuture().

      This method waits for the completion of the underlying asynchronous operation. If the operation completes successfully, the result is returned, otherwise the failure is thrown (potentially wrapped in a RuntimeException).

      Returns:
      the Void instance produced by the operation.

    • closeFutureAndForget

      public void closeFutureAndForget()
      Variant of closeFuture() that ignores the result of the operation.

      This method subscribes on the result of closeFuture(), but discards the outcome (item or failure). This method is useful to trigger the asynchronous operation from closeFuture() but you don't need to compose it with other operations.

    • unwrap

      public io.vertx.proton.ProtonConnection unwrap()
      Returns:
      the underlying ProtonConnection.

    • newInstance

      public static AmqpConnection newInstance(io.vertx.amqp.AmqpConnection arg)