catch (\Throwable
$e) { $exceptions[] =
$e;
} } /** @var FlushBatchHandlersStamp $flushStamp */
if ($flushStamp =
$envelope->
last(FlushBatchHandlersStamp::
class)) { /** @var NoAutoAckStamp $stamp */
foreach ($envelope->
all(NoAutoAckStamp::
class) as $stamp) { try { $handler =
$stamp->
getHandlerDescriptor()->
getBatchHandler();
$handler->
flush($flushStamp->
force());
} catch (\Throwable
$e) { $exceptions[] =
$e;
} } } if (null ===
$handler && !
$alreadyHandled) { if (!
$this->allowNoHandlers
) { throw new NoHandlerForMessageException(sprintf('No handler for message "%s".',
$context['class'
]));
}