0 follower

Final Class Yiisoft\Queue\Middleware\Push\SynchronousPushHandler

InheritanceYiisoft\Queue\Middleware\Push\SynchronousPushHandler
ImplementsYiisoft\Queue\Middleware\Push\PushHandlerInterface

Method Details

Hide inherited methods

__construct() public method

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

                public function __construct(
    private readonly WorkerInterface $worker,
    private readonly QueueInterface $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);
    return $message;
}