how to prevent message re-queue within rabbitmq server?

Question

I'm using direct exchange to publish messages to certain queues with routing keys, all configured in rabbit-server not code, I'm consuming messages with spring micro-service then some failures happens within the receiving method, then the message re-queued causing loop, so I'd like to add a policy with rabbit-server to prevent that kind of re-queuing, could it be added as an argument while binding queue with exchange with specific routing key, or it should be a policy ?

Manmay Manmay · Accepted Answer · 2016-06-02T14:13:09

On any exception by default spring send nack with requeue "true". If in your spring consumer application you want to send requeue false, then throw the exception "AmqpRejectAndDontRequeueException". So your consumer code should loook something like this :

`void onMessage(){
  try{
    // Your Code Here
  } catch(Exception e){
     throw new AmqpRejectAndDontRequeueException();
  }
}`

how to prevent message re-queue within rabbitmq server?

1 Answers