kknongchang_2506/app/Module/DelayQueue/Job/Job.php

<?php

namespace App\Module\DelayQueue\Job;

use App\Module\DelayQueue\Entity\Queue;
use UCore\Queue\QueueJob;


class Job extends QueueJob
{


    public function __construct(public Queue $arg)
    {

    }

    public function run(): bool
    {
        dump($this->arg,[$this->arg->runClass,$this->arg->runMethod]);
        $res = call_user_func([$this->arg->runClass,$this->arg->runMethod],$this->arg->runParam);
        dump($res);
        return true;
    }

    public function payload()
    {

        return $this->arg;
    }

}