Package io.micronaut.rabbitmq.bind

Interface RabbitAcknowledgement

All Superinterfaces:
io.micronaut.messaging.Acknowledgement
public interface RabbitAcknowledgement extends io.micronaut.messaging.Acknowledgement
A contract for acknowledging or rejecting RabbitMQ messages.
Since:
1.1.0
Author:
James Kleeh

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    ack()
     
    void
    ack(boolean multiple)
    Acknowledges this message.
    default void
    nack()
     
    void
    nack(boolean multiple, boolean reQueue)
    Rejects this message.

  • Method Details

    • ack

      default void ack() throws io.micronaut.messaging.exceptions.MessageAcknowledgementException
      Specified by:
      ack in interface io.micronaut.messaging.Acknowledgement
      Throws:
      io.micronaut.messaging.exceptions.MessageAcknowledgementException

    • nack

      default void nack() throws io.micronaut.messaging.exceptions.MessageAcknowledgementException
      Specified by:
      nack in interface io.micronaut.messaging.Acknowledgement
      Throws:
      io.micronaut.messaging.exceptions.MessageAcknowledgementException

    • ack

      void ack(boolean multiple) throws io.micronaut.messaging.exceptions.MessageAcknowledgementException
      Acknowledges this message.
      Parameters:
      multiple - If true, also acknowledge previous messages
      Throws:
      io.micronaut.messaging.exceptions.MessageAcknowledgementException - If an error occurred

    • nack

      void nack(boolean multiple, boolean reQueue) throws io.micronaut.messaging.exceptions.MessageAcknowledgementException
      Rejects this message.
      Parameters:
      multiple - If true, also reject previous messages
      reQueue - Re-queue the message to be consumed again
      Throws:
      io.micronaut.messaging.exceptions.MessageAcknowledgementException - If an error occurred