Ich arbeite mit ActiveMQ 5.8.0, ich habe eine Warteschlange und es empfängt Nachrichten von Zeit zu Zeit und werden sofort vom Listener dieser bestimmten Warteschlange verarbeitet, Hier möchte ich die Warteschlange, um die Nachricht nach 24 Stunden nicht sofort zu verarbeiten, gibt es einen Parameter in Active MQ, wo wir dies tun können.Wie mache ich eine Schlange zur Verarbeitung von Nachrichten nach 24 Stunden in ActiveMQ
Anstatt Verbraucher konsumieren die Nachrichten mit Verzögerung von 24 Stunden, würde ich es vorziehen, die Nachrichten in der Schlange mit der Verzögerung von 24 Stunden.
Wir können es
long time = 24 hours in milliseconds;
message.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY, time);
producer.send(message)
nach der Verwendung dieser Konfiguration mit tun, wird ActiveMQ die Nachricht Zeitplan durch Verzögerung von 24 Stunden geliefert werden.
PS: Sie werden nur eine kleine Sache überprüfen müssen, was passiert, wenn Broker geht, bevor die Nachricht übermittelt wird, und es erfolgreich gesendet geht, wenn Broker oben und wieder
Hoffnung läuft, das hilft!
Viel Glück!
Hi, vihar Ich kann das nicht, eigentlich bin ich auf der Suche nach Nachrichten von DLQ zu verarbeiten, wenn ich Nachrichten empfangen, die nicht erfolgreich von seiner Hauptwarteschlange verarbeitet werden. Ich versuche im Grunde, zu seiner Hauptwarteschlange nach 24 Stunden zu liefern oder direkt zu verarbeiten Nachricht nach 24 Stunden von DLQ. – user4045063
Erwähnen Sie diese außergewöhnlichen Szenarien, wenn Sie Fragen stellen – Vihar