diff --git a/Command/FailedMessagesRetryCommand.php b/Command/FailedMessagesRetryCommand.php index 3bf4f81c..ae47d774 100644 --- a/Command/FailedMessagesRetryCommand.php +++ b/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; + } } }