8000 bug #54050 [Messenger] Revert "Resend failed retries back to failure … · symfony/symfony@509aa06 · GitHub
[go: up one dir, main page]

Skip to content

Commit 509aa06

Browse files
committed
bug #54050 [Messenger] Revert "Resend failed retries back to failure transport " (ro0NL)
This PR was merged into the 6.4 branch. Discussion ---------- [Messenger] Revert "Resend failed retries back to failure transport " Reverts #51848 | Q | A | ------------- | --- | Branch? | 6.4 | Bug fix? | yes | New feature? | no | Deprecations? | no | Issues | Fix #... <!-- prefix each issue number with "Fix #", no need to create an issue if none exists, explain below instead --> | License | MIT See #53216, it's complex :') I suggest to get rid of confusion between `messenger:consume failed` vs. `bin/console messenger:failed:retry` somehow. cc `@beermeat` `@guelosuperstart` `@javaDeveloperKid` `@fabpot` Commits ------- 8dba632 [Messenger] Revert "Resend failed retries back to failure transport "
2 parents 923ee21 + 8dba632 commit 509aa06

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