0

Final Class Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy

All Classes | Methods
InheritanceYiisoft\Queue\Debug\QueueWorkerInterfaceProxy
ImplementsYiisoft\Queue\Worker\WorkerInterface

Debug proxy for {@see WorkerInterface} that records processed messages into the {@see QueueCollector}.

Public Methods

Hide inherited methods

Method Description Defined By
__construct() Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy
process() Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy

Method Details

Hide inherited methods

__construct() public method

public mixed __construct ( Yiisoft\Queue\Worker\WorkerInterface $worker, Yiisoft\Queue\Debug\QueueCollector $collector )
$worker Yiisoft\Queue\Worker\WorkerInterface
$collector Yiisoft\Queue\Debug\QueueCollector 

                public function __construct(
    private readonly WorkerInterface $worker,
    private readonly QueueCollector $collector,
) {}
process() public method

public void process ( Yiisoft\Queue\Message\MessageInterface $message, string $queueName )
$message Yiisoft\Queue\Message\MessageInterface
$queueName string 

                public function process(MessageInterface $message, string $queueName): void
{
    $this->collector->collectWorkerProcessing($message, $queueName);
    $this->worker->process($message, $queueName);
}