Package io.vertx.reactivex.core.eventbus

Class MessageProducer<T>

  • public class MessageProducer<T>
extends Object
    Represents a stream of message that can be written to.

    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<MessageProducer> __TYPE_ARG

      • __typeArg_0

        public final io.vertx.lang.rx.TypeArg<T> __typeArg_0

    • Constructor Detail

      • MessageProducer

        public MessageProducer​(Object delegate,
                       io.vertx.lang.rx.TypeArg<T> typeArg_0)

    • Method Detail

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object

      • deliveryOptions

        public MessageProducer<T> deliveryOptions​(DeliveryOptions options)
        Update the delivery options of this producer.
        Parameters:
        options - the new options
        Returns:
        this producer object

      • address

        public String address()
        Returns:
        The address to which the producer produces messages.

      • write

        public Future<Void> write​(T body)
        Write a message to the event-bus, either sending or publishing. The returned completion depends on the producer type:
        • send or request: the future is completed successfully if the message has been written; otherwise, the future is failed
        • publish: the future is failed if there is no recipient; otherwise, the future is completed successfully
        In any case, a successfully completed is not a delivery guarantee.
        Parameters:
        body - the message body
        Returns:

      • rxWrite

        public Completable rxWrite​(T body)
        Write a message to the event-bus, either sending or publishing. The returned completion depends on the producer type:
        • send or request: the future is completed successfully if the message has been written; otherwise, the future is failed
        • publish: the future is failed if there is no recipient; otherwise, the future is completed successfully
        In any case, a successfully completed is not a delivery guarantee.
        Parameters:
        body - the message body
        Returns:

      • close

        public Future<Void> close()
        Closes the producer, this method should be called when the message producer is not used anymore.
        Returns:
        a future completed with the result

      • rxClose

        public Completable rxClose()
        Closes the producer, this method should be called when the message producer is not used anymore.
        Returns:
        a future completed with the result