SpringAMQP-Verzögerung

Question

Ich habe Probleme, eine Möglichkeit zu finden, die Nachrichtenebene in SpringAMQP zu verzögern. Ich rufe einen Webservice auf, wenn der Dienst nicht verfügbar ist oder wenn er eine Ausnahme auslöst. Ich speichere alle Anfragen in der RabbitMQ-Warteschlange und versuche den Serviceaufruf solange, bis er erfolgreich ausgeführt wird. Wenn der Dienst einen Fehler anzeigt oder nicht verfügbar ist, führt der RabbitMQ-Listener eine Schleifenbildung durch (bedeutet, dass der Listener die Nachricht abruft und einen Dienst aufruft, falls ein Fehler auftritt)

Ich beschränkte die Schleifenbildung auf X Stunden mit MessagePostProcessor Ich wollte jedoch die Verzögerung auf Nachrichtenebene und bei jedem Zugriff auf den Dienst aktivieren. Zum Beispiel 1. versuchen Sie 3000ms Verzögerung und zweiten Mal 6000ms so weiter, bis ich x Zeit versuchen.

Es wäre großartig, wenn Sie ein paar Beispiele bereitstellen.

Könnten Sie mir bitte eine Idee dazu geben?

Answer 1

I added CustomeMessage delay exchange 

    @Bean 
    CustomExchange delayExchange() { 
     Map<String, Object> args = new HashMap<>(); 
     args.put("x-delayed-type", "direct"); 
     return new CustomExchange("delayed-exchange", "x-delayed-message", true, false, args); 
    } 

Added MessagePostProcessor 

    if (message.getMessageProperties().getHeaders().get("x-delay") == null) { 
      message.getMessageProperties().setHeader("x-delay", 10000); 
     } else { 

      Integer integer = (Integer) message.getMessageProperties().getHeaders().get("x-delay"); 
      if (integer < 60000) { 
       integer = integer + 10000; 
       message.getMessageProperties().setHeader("x-delay", integer); 
      } 
     } 

First time it delays 30 seconds and adds 10seconds each time till it reaches 600 seconds.This should be configurable. 

And finally send the message to 

    rabbitTemplate.convertAndSend("delayed-exchange", queueName,message, rabbitMQMessagePostProcessor); 

Answer 2

Nun, es ist nicht möglich, wie Sie das tun.

Message-Re-Queuing ist vollständig der Transaktion Rallback ähnlich, bei der das System in den Zustand vor einer Ausnahme zurückkehrt. Sie können also definitiv keine Nachricht ändern, um zur Warteschlange zurückzukehren.

Wahrscheinlich müssen Sie einen Blick in Spring Retry Projekt aus dem gleichen Grund und Poll-Nachricht aus der Warteschlange nur einmal und Versuche im Speicher, bis erfolgreiche Antwort oder Wiederholung der Politik anstrengend. Am Ende können Sie die Nachricht einfach aus der Warteschlange löschen oder in DLQ verschieben.

Weitere Informationen finden Sie in der Reference Manual.