Interface MessageProducer<T>

public interface MessageProducer<T>
Represents a stream of message that can be written to.

Author:
Julien Viet

  • Method Details

    • deliveryOptions

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

    • address

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

    • write

      Future<Void> write(T body)
      Write a message to the event-bus, either sending or publishing. The returned Future 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 Future is not a delivery guarantee.
      Parameters:
      body - the message body

    • close

      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