Queue
abstract class Queue (View source)
Traits
Properties
| protected Container | $container | The IoC container instance. |
|
| protected string | $connectionName | The connection name for the queue. |
|
| static protected callable[] | $createPayloadCallbacks | The create payload callbacks. |
Methods
Get the number of seconds until the given DateTime.
If the given value is an interval, convert it to a DateTime instance.
Push a new job onto the queue.
Push a new job onto the queue after a delay.
Push an array of jobs onto the queue.
Create a payload string from the given job and data.
Create a payload array from the given job and data.
Create a payload for an object-based queue handler.
Get the display name for the given job.
Get the retry delay for an object-based queue handler.
Get the expiration timestamp for an object-based queue handler.
Create a typical, string based queue payload array.
Register a callback to be executed when creating job payloads.
Create the given payload using any registered payload hooks.
Get the connection name for the queue.
Set the connection name for the queue.
Details
protected int
secondsUntil(DateTimeInterface|DateInterval|int $delay)
Get the number of seconds until the given DateTime.
protected int
availableAt(DateTimeInterface|DateInterval|int $delay = 0)
Get the "available at" UNIX timestamp.
protected DateTimeInterface|int
parseDateInterval(DateTimeInterface|DateInterval|int $delay)
If the given value is an interval, convert it to a DateTime instance.
protected int
currentTime()
Get the current system time as a UNIX timestamp.
mixed
pushOn(string $queue, string $job, mixed $data = '')
Push a new job onto the queue.
mixed
laterOn(string $queue, DateTimeInterface|DateInterval|int $delay, string $job, mixed $data = '')
Push a new job onto the queue after a delay.
void
bulk(array $jobs, mixed $data = '', string|null $queue = null)
Push an array of jobs onto the queue.
protected string
createPayload(string|object $job, string $queue, mixed $data = '')
Create a payload string from the given job and data.
protected array
createPayloadArray(string|object $job, string $queue, mixed $data = '')
Create a payload array from the given job and data.
protected array
createObjectPayload(object $job, string $queue)
Create a payload for an object-based queue handler.
protected string
getDisplayName(object $job)
Get the display name for the given job.
mixed
getJobRetryDelay(mixed $job)
Get the retry delay for an object-based queue handler.
mixed
getJobExpiration(mixed $job)
Get the expiration timestamp for an object-based queue handler.
protected array
createStringPayload(string $job, string $queue, mixed $data)
Create a typical, string based queue payload array.
static void
createPayloadUsing(callable $callback)
Register a callback to be executed when creating job payloads.
protected array
withCreatePayloadHooks(string $queue, array $payload)
Create the given payload using any registered payload hooks.
string
getConnectionName()
Get the connection name for the queue.
$this
setConnectionName(string $name)
Set the connection name for the queue.
void
setContainer(Container $container)
Set the IoC container instance.