8000 [Messenger] Revert "Resend failed retries back to failure transport " · symfony/symfony@8dba632 · GitHub
[go: up one dir, main page]

Skip to content

Commit 8dba632

Browse files
authored
[Messenger] Revert "Resend failed retries back to failure transport "
Reverts #51848
1 parent 7cda7b4 commit 8dba632

File tree

1 file changed

+5
-0
lines changed

1 file changed

+5
-0
lines changed

src/Symfony/Component/Messenger/EventListener/SendFailedMessageToFailureTransportListener.php

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,11 @@ public function onMessageFailed(WorkerMessageFailedEvent $event)
5252

5353
$envelope = $event->getEnvelope();
5454

55+
// avoid re-sending to the failed sender
56+
if (null !== $envelope->last(SentToFailureTransportStamp::class)) {
57+
return;
58+
}
59+
5560
$envelope = $envelope->with(
5661
new SentToFailureTransportStamp($event->getReceiverName()),
5762
new DelayStamp(0),

0 commit comments

Comments
 (0)
0