0

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, string $queueName, ?\Yiisoft\Queue\QueueProducerInterface $retryProducer = null )
$message Yiisoft\Queue\Message\MessageInterface
$queueName string
$retryProducer ?\Yiisoft\Queue\QueueProducerInterface 

                public function process(
    MessageInterface $message,
    string $queueName,
    ?QueueProducerInterface $retryProducer = null,
): MessageInterface {
    $this->collector->collectWorkerProcessing($message, $queueName);
    return $this->worker->process($message, $queueName, $retryProducer);
}