0

Final Class Yiisoft\Queue\Debug\QueueProducerDecorator

InheritanceYiisoft\Queue\Debug\QueueProducerDecorator
ImplementsYiisoft\Queue\QueueProducerInterface

Method Details

Hide inherited methods

__construct() public method

public mixed __construct ( Yiisoft\Queue\QueueProducerInterface $queue, Yiisoft\Queue\Debug\QueueCollector $collector )
$queue Yiisoft\Queue\QueueProducerInterface
$collector Yiisoft\Queue\Debug\QueueCollector

                public function __construct(private readonly QueueProducerInterface $queue, private readonly QueueCollector $collector) {}

            
getQueueName() public method

public string getQueueName ( )

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

            
push() public method

public Yiisoft\Queue\Message\MessageInterface push ( Yiisoft\Queue\Message\MessageInterface $message )
$message Yiisoft\Queue\Message\MessageInterface

                public function push(MessageInterface $message): MessageInterface
{ /** @psalm-var array{file: string, line: int} $stack */ $stack = debug_backtrace()[0];
    $message = $this->queue->push($message);
    $this->collector->collectPush($this->queue->getQueueName(), $message, $stack['file'] . ':' . $stack['line']);
    return $message;
}

            
status() public method

public \Yiisoft\Queue\MessageStatus status ( string|integer $id )
$id string|integer

                public function status(string|int $id): MessageStatus
{ /** @psalm-var array{file: string, line: int} $stack */ $stack = debug_backtrace()[0];
    $result = $this->queue->status($id);
    $this->collector->collectStatus((string) $id, $result, $stack['file'] . ':' . $stack['line']);
    return $result;
}