QueueManager

Create a pool proxy for an immutable definition.

Build a namespaced pool definition for a pooled resource.

Get the shared object-pool factory.

Set the release callback for a pooled driver.

The callback persists on the shared manager for the worker lifetime and is captured by every subsequently created proxy for the driver.

Get the release callback for a pooled driver.

Add a driver to the poolable-driver list.

The list persists on the manager for the worker lifetime and is consulted on subsequent driver creation. Per-request use races across coroutines and does not affect already-cached drivers.

Remove a driver from the poolable-driver list.

The list persists on the manager for the worker lifetime and is consulted on subsequent driver creation. Per-request use races across coroutines and does not affect already-cached drivers.

Get the poolable-driver list.

Set the poolable-driver list.

The list persists on the manager for the worker lifetime and is consulted on subsequent driver creation. Per-request use races across coroutines and does not affect already-cached drivers.

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.

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.

Create a new queue manager instance.

Register an event listener for the before job event.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register an event listener for the after job event.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register an event listener for the exception occurred job event.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register an event listener for the daemon queue loop.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register an event listener for the failed job event.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register an event listener for the daemon queue starting.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register an event listener for the daemon queue stopping.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register a callback to be invoked when a job runs for longer than a given amount of time.

The listener persists on the singleton event dispatcher for the worker lifetime and runs for every subsequent matching queue event.

Register the default queue route for a given class.

The route persists on the singleton QueueRoutes registry for the worker lifetime and affects every subsequent dispatch of that class.

Forward the given queue to another queue and/or connection.

Forwards persist on the singleton QueueRoutes registry for the worker lifetime and affect every subsequent dispatch and queue operation.

Pause a queue by its name and connection.

Pause a queue by its name and connection for a given amount of time.

Pause job processing for all queues on all connections.

Resume a paused queue by its name and connection.

Resume job processing for all queues on all connections.

Queues paused individually are not affected.

Determine if a queue is paused.

Determine which of the given queues are currently paused.

Indicate that queue workers should not poll for restart or pause signals.

This prevents the workers from hitting the application cache to determine if they need to pause or restart.

Mutates process-global worker flags; runtime use races across coroutines and changes every concurrent worker pause or restart check.

Determine if the driver is connected.

Resolve a queue connection instance.

Resolve a queue connection.

Reject circular definitions owned by the resolved failover connector.

Get the connector for a given driver.

Add a queue connection resolver.

The resolver persists in the singleton's connectors array for the worker lifetime and applies to every subsequent connection.

Add a queue connection resolver.

The resolver persists in the singleton's connectors array for the worker lifetime and applies to every subsequent connection.

Get the queue connection configuration.

Get the name of the default queue connection.

Set the name of the default queue connection.

Mutates process-global config; per-request use races across coroutines.

Get the full name for the given connection.

Disconnect a queue connection and close its shared resource pool.

Use this to recover broken pooled resources. Other connections sharing the pool transparently acquire a fresh pool on their next operation.

Get the application instance used by the manager.

Set the application instance used by the manager.

Swaps the container reference on the singleton and on every cached queue connection; per-request use races across coroutines and breaks every concurrent dispatch.

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.

Dynamically pass calls to the default connection.