49 lines
1.3 KiB
PHP
49 lines
1.3 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;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* 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
|
||
|
|
{
|
||
|
|
private $exceptions;
|
||
|
|
|
||
|
|
public function __construct(array $exceptions)
|
||
|
|
{
|
||
|
|
$exceptionMessages = implode(", \n", array_map(
|
||
|
|
function (\Throwable $e) {
|
||
|
|
return \get_class($e).': '.$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[0]);
|
||
|
|
}
|
||
|
|
|
||
|
|
public function getExceptions(): array
|
||
|
|
{
|
||
|
|
return $this->exceptions;
|
||
|
|
}
|
||
|
|
}
|