Package io.vertx.rxjava3.amqp

Class AmqpConnection

  • All Implemented Interfaces:
    io.vertx.lang.rx.RxDelegate
    public class AmqpConnection
extends Object
implements io.vertx.lang.rx.RxDelegate
    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 RX-ified interface using Vert.x codegen.

    • Field Detail

      • __TYPE_ARG

        public static final io.vertx.lang.rx.TypeArg<AmqpConnection> __TYPE_ARG

    • Constructor Detail

      • AmqpConnection

        public AmqpConnection​(Object delegate)

    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object

      • getDelegate

        public AmqpConnection getDelegate()
        Specified by:
        getDelegate in interface io.vertx.lang.rx.RxDelegate

      • exceptionHandler

        public AmqpConnection exceptionHandler​(Handler<Throwable> handler)
        Registers a handler called on disconnection.
        Parameters:
        handler - the exception handler.
        Returns:
        the connection

      • close

        public Completable close()
        Closes the AMQP connection, i.e. allows the Close frame to be emitted.
        Returns:
        a future notified when the connection is closed

      • rxClose

        public Completable rxClose()
        Closes the AMQP connection, i.e. allows the Close frame to be emitted.
        Returns:
        a future notified when the connection is closed

      • createReceiver

        public Single<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.
        Parameters:
        address - The source address to attach the consumer to, must not be null
        Returns:
        a future notified with the receiver. The receiver has been opened.

      • rxCreateReceiver

        public Single<AmqpReceiver> rxCreateReceiver​(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.
        Parameters:
        address - The source address to attach the consumer to, must not be null
        Returns:
        a future notified with the receiver. The receiver has been opened.

      • createReceiver

        public Single<AmqpReceiver> createReceiver​(String address,
                                           AmqpReceiverOptions receiverOptions)
        Creates a receiver used to consumer messages from the given address.
        Parameters:
        address - The source address to attach the consumer to.
        receiverOptions - The options for this receiver.
        Returns:
        a future notified with the receiver, once opened. Note that the messageHandler can be called before the completionHandler if messages are awaiting delivery.

      • rxCreateReceiver

        public Single<AmqpReceiver> rxCreateReceiver​(String address,
                                             AmqpReceiverOptions receiverOptions)
        Creates a receiver used to consumer messages from the given address.
        Parameters:
        address - The source address to attach the consumer to.
        receiverOptions - The options for this receiver.
        Returns:
        a future notified with the receiver, once opened. Note that the messageHandler can be called before the completionHandler if messages are awaiting delivery.

      • createDynamicReceiver

        public Single<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.
        Returns:
        a future notified when the receiver has been created and opened.

      • rxCreateDynamicReceiver

        public Single<AmqpReceiver> rxCreateDynamicReceiver()
        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.
        Returns:
        a future notified when the receiver has been created and opened.

      • createSender

        public Single<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().
        Parameters:
        address - The target address to attach to, must not be null
        Returns:
        a future notified with the sender, once opened

      • rxCreateSender

        public Single<AmqpSender> rxCreateSender​(String address)
        Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
        Parameters:
        address - The target address to attach to, must not be null
        Returns:
        a future notified with the sender, once opened

      • createSender

        public Single<AmqpSender> createSender​(String address,
                                       AmqpSenderOptions options)
        Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
        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:
        a future notified with the sender, once opened

      • rxCreateSender

        public Single<AmqpSender> rxCreateSender​(String address,
                                         AmqpSenderOptions options)
        Creates a sender used to send messages to the given address. The address must be set. For anonymous sender, check createAnonymousSender().
        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:
        a future notified with the sender, once opened

      • createAnonymousSender

        public Single<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.

        Returns:
        a future notifid with the created sender, once opened

      • rxCreateAnonymousSender

        public Single<AmqpSender> rxCreateAnonymousSender()
        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.

        Returns:
        a future notifid with the created sender, once opened

      • isDisconnected

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

      • closeFuture

        public Completable closeFuture()
        Returns:
        a future completed when the connection is closed

      • rxCloseFuture

        public Completable rxCloseFuture()
        Returns:
        a future completed when the connection is closed

      • unwrap

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