Class AmqpMessage<T>

    • Constructor Detail

      • AmqpMessage

        public AmqpMessage​(io.vertx.mutiny.amqp.AmqpMessage delegate,
                           io.vertx.mutiny.core.Context context,
                           AmqpFailureHandler onNack)
      • AmqpMessage

        public AmqpMessage​(io.vertx.amqp.AmqpMessage msg,
                           io.vertx.mutiny.core.Context context,
                           AmqpFailureHandler onNack)
    • Method Detail

      • ack

        public CompletionStage<Void> ack()
        Description copied from interface: Message
        Acknowledge this message.
        Specified by:
        ack in interface Message<T>
        Returns:
        a completion stage completed when the message is acknowledged. If the acknowledgement fails, the completion stage propagates the failure.
      • nack

        public CompletionStage<Void> nack​(Throwable reason)
        Description copied from interface: Message
        Acknowledge negatively this message. nack is used to indicate that the processing of a message failed. The reason is passed as parameter.
        Specified by:
        nack in interface Message<T>
        Parameters:
        reason - the reason of the nack, must not be null
        Returns:
        a completion stage completed when the message is negative-acknowledgement has completed. If the negative acknowledgement fails, the completion stage propagates the failure.
      • getPayload

        public T getPayload()
        Specified by:
        getPayload in interface Message<T>
        Returns:
        The payload for this message.
      • getMetadata

        public Metadata getMetadata()
        Specified by:
        getMetadata in interface Message<T>
        Returns:
        The set of metadata attached to this message, potentially empty.
      • unwrap

        public org.apache.qpid.proton.message.Message unwrap()
      • isDurable

        public boolean isDurable()
      • getDeliveryCount

        public long getDeliveryCount()
      • getPriority

        public int getPriority()
      • getTtl

        public long getTtl()
      • getMessageId

        public Object getMessageId()
      • getGroupSequence

        public long getGroupSequence()
      • getCreationTime

        public long getCreationTime()
      • getAddress

        public String getAddress()
      • getGroupId

        public String getGroupId()
      • getContentType

        public String getContentType()
      • getExpiryTime

        public long getExpiryTime()
      • getCorrelationId

        public Object getCorrelationId()
      • getContentEncoding

        public String getContentEncoding()
      • getSubject

        public String getSubject()
      • getApplicationProperties

        public io.vertx.core.json.JsonObject getApplicationProperties()
      • getBody

        public org.apache.qpid.proton.amqp.messaging.Section getBody()
      • getError

        public org.apache.qpid.proton.message.MessageError getError()
      • getAmqpMessage

        public io.vertx.mutiny.amqp.AmqpMessage getAmqpMessage()