$this->
printPendingMessagesMessage($receiver,
$io);
$io->
writeln(sprintf('To retry all the messages, run <comment>messenger:consume %s</comment>',
$failureTransportName));
$shouldForce =
$input->
getOption('force'
);
$ids =
$input->
getArgument('id'
);
if (0 === \
count($ids)) { if (!
$input->
isInteractive()) { throw new RuntimeException('Message id must be passed when in non-interactive mode.'
);
} $this->
runInteractive($failureTransportName,
$io,
$shouldForce);
return 0;
} $this->
retrySpecificIds($failureTransportName,
$ids,
$io,
$shouldForce);
$io->
success('All done!'
);
return 0;
} private function runInteractive(string
$failureTransportName, SymfonyStyle
$io, bool
$shouldForce): void
{