Wie kann man verhindern, dass die Nachricht innerhalb des rabbitmq-Servers neu ansteht?

Question

Ich verwende direkten Austausch, um Nachrichten zu bestimmten Warteschlangen mit Routing-Schlüssel zu veröffentlichen, alle in Kaninchen-Server-Code nicht konfiguriert, ich nehme Nachrichten mit Feder Micro-Service dann einige Fehler innerhalb der Empfangsmethode passiert, dann die Nachricht re -wurde verursacht Schleife, so würde ich gerne eine Richtlinie mit Kaninchen-Server hinzufügen, um diese Art von Neueinreihen zu verhindern, könnte es als ein Argument hinzugefügt werden, während Bindung Warteschlange mit Austausch mit bestimmten Routing-Schlüssel, oder es sollte eine Richtlinie sein ?

Answer 1

Bei jeder Ausnahme standardmäßig Spring senden nack mit requeue "true". Wenn Sie in Ihrer Frühlingsbenutzeranwendung requeue false senden möchten, dann werfen Sie die Ausnahme "AmqpRejectAndDontRequeueException". So sollte Ihr Verbraucher Code so etwas wie dieses loook:

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