$instance : mixed
The job handler instance.
$queue : string
The name of the queue the job belongs to.
$deleted : boolean
Indicates if the job has been deleted.
$released : boolean
Indicates if the job has been released.
$redis : \think\queue\connector\Redis
The redis queue instance.
$job : Object
The database job payload.
fire() : void
Fire the job.
delete() : void
isDeleted() : boolean
Determine if the job has been deleted.
release(integer $delay) : void
isReleased() : boolean
Determine if the job was released back into the queue.
isDeletedOrReleased() : boolean
Determine if the job has been deleted or released.
attempts() : integer
Get the number of times the job has been attempted.
getRawBody() : string
Get the raw body string for the job.
failed() : void
Call the failed method on the job instance.
getName() : string
Get the name of the queued job class.
getQueue() : string
Get the name of the queue the job belongs to.
__construct(\think\queue\connector\Redis $redis, $job, $queue)
resolveAndFire(array $payload) : void
Resolve and fire the job handler method.
parseJob(string $job) : array
Parse the job declaration into class and method.
resolve(string $name) : mixed
Resolve the given job handler.
getSeconds(\DateTime|integer $delay) : integer
Calculate the number of seconds with the given delay.
getTime() : integer
Get the current system time.