Yiisoft\Queue\Exception\JobFailureException

Complexity

Total Complexity

2

Size/Duplication

Total Lines	14
Duplicated Lines	0 %

Test Coverage

Coverage

71.43%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	getQueueMessage()	0	3	1

<?php

declare(strict_types=1);

namespace Yiisoft\Queue\Exception;

use RuntimeException;
use Throwable;
use Yiisoft\Queue\Message\MessageInterface;
use Yiisoft\Queue\Message\IdEnvelope;

class JobFailureException extends RuntimeException
{
    public function __construct(private MessageInterface $queueMessage, Throwable $previous)
    {
        $error = $previous->getMessage();
        $messageId = $queueMessage->getMetadata()[IdEnvelope::MESSAGE_ID_KEY] ?? 'null';
        $messageText = "Processing of message #$messageId is stopped because of an exception:\n$error.";

        parent::__construct($messageText, 0, $previous);
    }

    public function getQueueMessage(): MessageInterface
    {
        return $this->queueMessage;
    }
}