io.micronaut.configuration.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 and Description
default void	ack()
void	ack(boolean multiple) Acknowledges this message.
default void	nack()
void	nack(boolean multiple, boolean reQueue) Rejects this message.

Method Detail

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