59 lines
1.8 KiB
PHP
59 lines
1.8 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of the Symfony package.
|
|
*
|
|
* (c) Fabien Potencier <fabien@symfony.com>
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
namespace Symfony\Component\Messenger\Exception;
|
|
|
|
use Symfony\Component\Messenger\Envelope;
|
|
|
|
/**
|
|
* When handling queued messages from {@link DispatchAfterCurrentBusMiddleware},
|
|
* some handlers caused an exception. This exception contains all those handler exceptions.
|
|
*
|
|
* @author Tobias Nyholm <tobias.nyholm@gmail.com>
|
|
*/
|
|
class DelayedMessageHandlingException extends RuntimeException implements WrappedExceptionsInterface, EnvelopeAwareExceptionInterface
|
|
{
|
|
use EnvelopeAwareExceptionTrait;
|
|
use WrappedExceptionsTrait;
|
|
|
|
private array $exceptions;
|
|
|
|
public function __construct(array $exceptions, ?Envelope $envelope = null)
|
|
{
|
|
$this->envelope = $envelope;
|
|
|
|
$exceptionMessages = implode(", \n", array_map(
|
|
fn (\Throwable $e) => $e::class.': '.$e->getMessage(),
|
|
$exceptions
|
|
));
|
|
|
|
if (1 === \count($exceptions)) {
|
|
$message = sprintf("A delayed message handler threw an exception: \n\n%s", $exceptionMessages);
|
|
} else {
|
|
$message = sprintf("Some delayed message handlers threw an exception: \n\n%s", $exceptionMessages);
|
|
}
|
|
|
|
$this->exceptions = $exceptions;
|
|
|
|
parent::__construct($message, 0, $exceptions[array_key_first($exceptions)]);
|
|
}
|
|
|
|
/**
|
|
* @deprecated since Symfony 6.4, use {@see self::getWrappedExceptions()} instead
|
|
*/
|
|
public function getExceptions(): array
|
|
{
|
|
trigger_deprecation('symfony/messenger', '6.4', 'The "%s()" method is deprecated, use "%s::getWrappedExceptions()" instead.', __METHOD__, self::class);
|
|
|
|
return $this->exceptions;
|
|
}
|
|
}
|