DatabaseQueue

Determine whether the job selects outbox delivery.

Run a child attempt or handler with its own forwarding context.

Avoid a second durable table when the jobs insert already belongs to its owner.

Select an explicit transaction for a local or failover after-commit fallback.

Stage a single job through its normal guarded enqueue lifecycle.

Stage selected jobs in owner groups and return the direct remainder.

Build a byte-preserving row from a finalized payload.

Capture the logical destination before publication-time forwarding.

Add metadata required while the original job is still available.

Capture transport options that cannot be recovered from the stored envelope.

Publish delayed database jobs immediately with their future availability.

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.

Immediate and after-commit jobs use one bulk insert per attempted group. Deferred groups reacquire the queue through the after-commit dispatcher, and the return value remains null when every job is deferred.

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

Get the delay configured on the given job.

Run an operation with its own log context, then restore the caller.

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 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.

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.

Queue connection instances are cached on QueueManager; replacing the dispatcher on a shared connection changes every subsequent after-commit enqueue through it.

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.

Run deferred work with its dispatch locks and optional deferredDispatchFailed job hook.

Enqueue a job immediately using the given callback.

Prepare a finalized payload for storage without changing lifecycle event correlation.

Handle a payload after the queue has accepted it.

Notify every batch member and return the first ordinary notification failure.

A canceled notification does not skip the remaining members; the first cancellation is rethrown once every member has been notified, and the ordinary failure it displaces is reported.

Notify every batch member of a failure or cancellation, reporting listener errors so they cannot replace it.

Report a failure that must not replace the primary error, without swallowing cancellation.

Finalize an encoded payload immediately before queueing.

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

Keep an already-atomic outbox-selected insert inside its transaction.

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, or the canceled event when cancellation stopped the job.

Raise the job queueing canceled event.

The cancellation is already propagating, so a listener failure is reported instead of replacing it.

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.

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.

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.

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

Flush all static state.

Determine if the given exception was caused by a concurrency error such as a deadlock or serialization failure.

Determine if the given exception was caused by a lost connection.

Insert database rows without exceeding the connection's binding limit.

Insert one database row chunk.

Get the statement binding limit without requiring a PDO-backed custom driver.

Create a new database 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 creation timestamp of the oldest pending job, excluding delayed jobs.

Push a new job onto the queue.

Push a raw payload onto the queue.

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

Insert a prepared batch and raise its queue lifecycle events.

Release accepted dispatch locks if their stored job is rolled back.

Publish a raw outbox batch atomically across its logical queues.

Release a reserved job back onto the queue after (n) seconds.

Push a raw payload to the database with a given delay of (n) seconds.

Create an array to insert for the given job.

Pop the next job off of the queue.

Get the next available job for the queue.

Get the lock required for popping the next job.

Modify the query to check for available jobs.

Modify the query to check for jobs that are reserved but have expired.

Marshal the reserved job into a DatabaseJob instance.

Mark the given job ID as reserved.

Determine whether the exception matches this job's reservation update.

Override this alongside markJobAsReserved when changing its SQL or bindings.

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 the queue or return the default.

Get the underlying database connection.