diff --git a/src/Symfony/Component/Messenger/Command/FailedMessagesRetryCommand.php b/src/Symfony/Component/Messenger/Command/FailedMessagesRetryCommand.php index 3bf4f81c03f7c..ae47d774b51c4 100644 --- a/src/Symfony/Component/Messenger/Command/FailedMessagesRetryCommand.php +++ b/src/Symfony/Component/Messenger/Command/FailedMessagesRetryCommand.php @@ -124,7 +124,10 @@ protected function execute(InputInterface $input, OutputInterface $output): int } $this->retrySpecificIds($failureTransportName, $ids, $io, $shouldForce); - $io->success('All done!'); + + if (!$this->shouldStop) { + $io->success('All done!'); + } return 0; } @@ -255,6 +258,10 @@ private function retrySpecificIds(string $failureTransportName, array $ids, Symf $singleReceiver = new SingleMessageReceiver($receiver, $envelope); $this->runWorker($failureTransportName, $singleReceiver, $io, $shouldForce); + + if ($this->shouldStop) { + break; + } } }