0 follower

Final Class Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy

All Classes | Methods

Inheritance	Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy
Implements	Yiisoft\Queue\Worker\WorkerInterface

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 __construct( Yiisoft\Queue\Worker\WorkerInterface $worker, Yiisoft\Queue\Debug\QueueCollector $collector ): mixed
$worker	Yiisoft\Queue\Worker\WorkerInterface
$collector	Yiisoft\Queue\Debug\QueueCollector

Source code

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

process() public method

public process( Yiisoft\Queue\Message\MessageInterface $message, Yiisoft\Queue\QueueInterface $queue ): Yiisoft\Queue\Message\MessageInterface
$message	Yiisoft\Queue\Message\MessageInterface
$queue	Yiisoft\Queue\QueueInterface

Source code

                public function process(MessageInterface $message, QueueInterface $queue): MessageInterface
{
    $this->collector->collectWorkerProcessing($message, $queue);
    return $this->worker->process($message, $queue);
}