0 follower

Final Class Yiisoft\Queue\Debug\QueueWorkerInterfaceProxy

All Classes | Methods
InheritanceYiisoft\Queue\Debug\QueueWorkerInterfaceProxy
ImplementsYiisoft\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 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 Yiisoft\Queue\Message\MessageInterface process ( Yiisoft\Queue\Message\MessageInterface $message, Yiisoft\Queue\QueueInterface $queue )
$message Yiisoft\Queue\Message\MessageInterface
$queue Yiisoft\Queue\QueueInterface 

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