RedisQueue

Get the number of seconds until the given DateTime.

Get the "available at" UNIX timestamp.

If the given value is an interval, convert it to a DateTime instance.

Get the current system time as a UNIX timestamp.

Given a start time, format the total run time for human readability.

Get a configuration value from an attribute, falling back to a property.

Extract the value from an attribute instance.

Get an instance of the given attribute class from the target class or its parents.

Determine if a property declared on a child class overrides an inherited attribute.

Resolve the default connection name for a given queueable instance.

Resolve the default queue name for a given queueable instance.

Get the queue routes manager instance.

Get the container that owns the queue routes.

Push a new job onto the queue.

Push a new job onto a specific queue after (n) seconds.

Push an array of jobs onto the queue.

Get the delay configured on the given job.

Create a payload string from the given job and data.

Create a payload string 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 maximum number of attempts for an object-based queue handler.

Get the backoff for an object-based queue handler.

Get the expiration timestamp for an object-based queue handler.

Determine if the job should be encrypted.

Create a typical, string based queue payload array.

Register a callback to be executed when creating job payloads.

Boot-only. The callback persists in a static property for the worker lifetime and runs on every subsequent payload creation across all coroutines. Passing null clears the registry.

Create the given payload using any registered payload hooks.

Set the dispatcher for after-commit queue operations.

Enqueue a job using the given callback.

The callback receives the queue that owns the operation first so deferred pooled dispatch never retains a borrowed queue.

Defer an enqueue operation until the applicable transaction commits.

Defer a batch enqueue operation until the applicable transaction commits.

Enqueue a job immediately using the given callback.

Finalize an encoded payload immediately before queueing.

Partition jobs by whether they should be deferred until the active transaction commits.

Determine if the job should be dispatched after the open parent database transactions have committed.

Register a transaction rollback callback that releases the job's locks.

Create a callback that releases the job's locks.

Mark a job's dispatch locks as accepted by the queue.

Raise the job queueing event.

Raise the job queueing failed event.

Raise the job queued event.

Normalize an enum queue name without applying defaults or forwarding.

Get the routed queue name for the given queue.

Get the connection name for the queue.

Set the connection name for the queue.

Boot or tests only. Queue connection instances are cached on QueueManager; runtime use races across coroutines and changes every concurrent dispatch through this connection.

Get the queue configuration array.

Set the queue configuration array.

Boot or tests only. Queue connection instances are cached on QueueManager; runtime use races across coroutines and changes every concurrent dispatch through this connection.

Get the container instance being used by the connection.

Set the IoC container instance.

Boot or tests only. Queue connection instances are cached on QueueManager; runtime use races across coroutines and changes every concurrent dispatch through this connection.

Flush all static state.

Create a new Redis queue instance.

Get the size of the queue.

Get the number of pending jobs.

Get the number of delayed jobs.

Get the number of reserved jobs.

Get the number of jobs across every queue.

Get the number of pending jobs across every queue.

Get the number of delayed jobs across every queue.

Get the number of reserved jobs across every queue.

Get the pending jobs for the given queue.

Get the delayed jobs for the given queue.

Get the reserved jobs for the given queue.

Get all pending jobs across every queue.

Get all delayed jobs across every queue.

Get all reserved jobs across every queue.

Get the unique queue names.

Get the unique queue names using an already-held raw connection.

Inspect jobs from one queue while holding one Redis connection.

Inspect jobs across every queue while holding one Redis connection.

Inspect one Redis queue using an already-held raw connection.

Inspect a formatted storage key while retaining the requested queue identity.

Get the creation timestamp of the oldest pending job, excluding delayed jobs.

Prepare the payload and delay for each of the given jobs.

Store a prepared batch and raise its queue lifecycle events.

Prepare a payload for bulk storage.

Handle a payload that was stored as part of a batch.

Push a new job onto the queue.

Push a raw payload onto the queue.

Push a new job onto the queue after a delay.

Push a raw job onto the queue after (n) seconds.

Pop the next job off of the queue.

Migrate any delayed or expired jobs onto the primary queue.

Migrate the delayed jobs that are ready to the regular queue.

Retrieve the next job from the queue.

Delete a reserved job from the queue.

Delete a reserved job from the reserved queue and release it.

Delete all of the jobs from the queue.

Get a random ID string.

Get the queue or return the default.

Get the cluster-safe Redis key for the given queue.

Queue names are forwarded once before adding the storage prefix and hash tag.

Format a physical queue name as a cluster-safe Redis key.

Redis Cluster requires every key passed to a multi-key Lua script to live on the same hash slot. Only storage keys are hash-tagged here.

Determine if the queue connection is a Redis Cluster connection.

Get the connection for the queue.

Get the underlying Redis instance.

Get the number of queue jobs that are ready to process.

Fire the given event if a dispatcher is bound.

Determine if the given Horizon event has listeners.

Set the job that last pushed to queue via the "push" method.