0

Final Class Yiisoft\Queue\Middleware\Push\SynchronousPushHandler

All Classes | Methods
InheritanceYiisoft\Queue\Middleware\Push\SynchronousPushHandler
ImplementsYiisoft\Queue\Middleware\Push\PushHandlerInterface

Public Methods

Hide inherited methods

Method Description Defined By
__construct() Yiisoft\Queue\Middleware\Push\SynchronousPushHandler
handlePush() Yiisoft\Queue\Middleware\Push\SynchronousPushHandler

Method Details

Hide inherited methods

__construct() public method

public mixed __construct ( Yiisoft\Queue\Worker\WorkerInterface $worker, Yiisoft\Queue\QueueProducerInterface $queue )
$worker Yiisoft\Queue\Worker\WorkerInterface
$queue Yiisoft\Queue\QueueProducerInterface 

                public function __construct(
    private readonly WorkerInterface $worker,
    private readonly QueueProducerInterface $queue,
) {}
handlePush() public method

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

                public function handlePush(MessageInterface $message): MessageInterface
{
    $this->worker->process($message, $this->queue->getQueueName(), $this->queue);
    return $message;
}