$envelopes[] =
$envelope;
} } finally { $this->phpSerializer?->
rejectPhpIncompleteClass();
} // break the loop if all messages are consumed
if (0 === \
count($envelopes)) { break;
} $this->
retrySpecificEnvelopes($envelopes,
$failureTransportName,
$io,
$shouldForce);
} } else { // get() and ask messages one-by-one
$count =
$this->
runWorker($failureTransportName,
$receiver,
$io,
$shouldForce);
} // avoid success message if nothing was processed
if (1 <=
$count) { $io->
success('All failed messages have been handled or removed!'
);
} }