Yiisoft\Yii\Debug\Collector\QueueDecorator

Complexity

Total Complexity

7

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes	1
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	3	1
A	push()	0	4	1
A	status()	0	6	1
A	getChannelName()	0	3	1
A	__construct()	0	4	1
A	listen()	0	3	1
A	withAdapter()	0	3	1

<?php

declare(strict_types=1);

namespace Yiisoft\Yii\Debug\Collector;

use Yiisoft\Yii\Queue\Adapter\AdapterInterface;
use Yiisoft\Yii\Queue\Enum\JobStatus;
use Yiisoft\Yii\Queue\Message\MessageInterface;
use Yiisoft\Yii\Queue\QueueInterface;

final class QueueDecorator implements QueueInterface
{
    public function __construct(
        private QueueInterface $queue,
        private QueueCollector $collector,
    ) {
    }

    public function status(string $id): JobStatus
    {
        $result = $this->queue->status($id);
        $this->collector->collectStatus($id);

        return $result;
    }

    public function push(MessageInterface $message): void
    {
        $this->queue->push($message);
        $this->collector->collectPush($this->queue->getChannelName(), $message);
    }

    public function run(int $max = 0): void
    {
        $this->queue->run($max);
    }

    public function listen(): void
    {
        $this->queue->listen();
    }

    public function withAdapter(AdapterInterface $adapter): QueueInterface
    {
        return $this->queue->withAdapter($adapter);
    }

    public function getChannelName(): string
    {
        return $this->queue->getChannelName();
    }
}