From 8dba6327ce64358067adee81d439d91c3918c723 Mon Sep 17 00:00:00 2001 From: "Roland Franssen :)" Date: Sat, 24 Feb 2024 18:14:30 +0100 Subject: [PATCH] [Messenger] Revert "Resend failed retries back to failure transport " Reverts #51848 --- .../SendFailedMessageToFailureTransportListener.php | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/Symfony/Component/Messenger/EventListener/SendFailedMessageToFailureTransportListener.php b/src/Symfony/Component/Messenger/EventListener/SendFailedMessageToFailureTransportListener.php index 2c4747173e02b..18b255190ee19 100644 --- a/src/Symfony/Component/Messenger/EventListener/SendFailedMessageToFailureTransportListener.php +++ b/src/Symfony/Component/Messenger/EventListener/SendFailedMessageToFailureTransportListener.php @@ -52,6 +52,11 @@ public function onMessageFailed(WorkerMessageFailedEvent $event) $envelope = $event->getEnvelope(); + // avoid re-sending to the failed sender + if (null !== $envelope->last(SentToFailureTransportStamp::class)) { + return; + } + $envelope = $envelope->with( new SentToFailureTransportStamp($event->getReceiverName()), new DelayStamp(0),