$failureTransportName =
$input->
getOption('transport'
);
if (self::DEFAULT_TRANSPORT_OPTION ===
$failureTransportName) { $failureTransportName =
$this->
getGlobalFailureReceiverName();
} $receiver =
$this->
getReceiver($failureTransportName);
$shouldForce =
$input->
getOption('force'
);
$ids =
(array) $input->
getArgument('id'
);
$shouldDisplayMessages =
$input->
getOption('show-messages'
) || 1 === \
count($ids);
$this->
removeMessages($failureTransportName,
$ids,
$receiver,
$io,
$shouldForce,
$shouldDisplayMessages);
return 0;
} private function removeMessages(string
$failureTransportName, array
$ids, ReceiverInterface
$receiver, SymfonyStyle
$io, bool
$shouldForce, bool
$shouldDisplayMessages): void
{ if (!
$receiver instanceof ListableReceiverInterface
) { throw new RuntimeException(sprintf('The "%s" receiver does not support removing specific messages.',
$failureTransportName));
} foreach ($ids as $id) {