QueueTask
abstract class QueueTask (View source)
Traits
Properties
| protected string | $queue | Define the queue |
|
| protected int | $delay | Define the delay |
|
| protected int | $retry | Define the time of retry |
|
| protected int | $priority | Define the priority |
|
| protected bool | $delete | Determine if the task can be deleted |
|
| protected string|null | $id | Define the task id |
|
| protected int | $attempts | Define the task attempts |
Methods
Worker constructor
Get the worker priority
Get the worker id
Get the worker attempts
Set the worker attempts
Get the worker retry
Set the worker retry
Get the worker queue
Set the worker queue
Get the worker delay
Set the worker delay
Delete the task from queue.
Delete the task from queue.
Process the task
Details
array
__serialize()
Prepare the instance values for serialization.
protected mixed
getPropertyValue(ReflectionProperty $property)
Get the property value for the given property.
void
__unserialize(array $values)
Restore the model after serialization.
void
__construct()
Worker constructor
final int
getPriority()
Get the worker priority
string
getId()
Get the worker id
int
getAttempts()
Get the worker attempts
void
setAttempts(int $attempts)
Set the worker attempts
final int
getRetry()
Get the worker retry
final void
setRetry(int $retry)
Set the worker retry
final string
getQueue()
Get the worker queue
final void
setQueue(string $queue)
Set the worker queue
final int
getDelay()
Get the worker delay
final void
setDelay(int $delay)
Set the worker delay
void
deleteTask()
Delete the task from queue.
bool
taskShouldBeDelete()
Delete the task from queue.
void
onException(Throwable $e)
Get the task error
abstract void
process()
Process the task