QueueFake

Create a pool proxy for an immutable definition.

Build a namespaced pool definition for a pooled resource.

Get the pool factory used by this manager.

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

Override the QueueManager to prevent circular dependency.

Resolve a truth-test callback or an array of expected properties.

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.

Get the class name of the first parameter of the given Closure.

Get the class names of the first parameter of the given Closure, including union types.

Get the class names / types of the parameters of the given Closure.

Get the class names / types of the return type of the given Closure.

Specify the jobs that should be queued instead of faked.

Assert if a job was pushed based on a truth-test callback.

Assert if a job was pushed a number of times.

Assert if a job was pushed exactly once.

Assert if a job was pushed based on a truth-test callback.

Assert if a job was pushed with chained jobs based on a truth-test callback.

Assert if a job was pushed with an empty chain based on a truth-test callback.

Assert if a job was pushed with chained jobs based on a truth-test callback.

Assert if a job was pushed with chained jobs based on a truth-test callback.

Assert if a closure was pushed based on a truth-test callback.

Assert that a closure was not pushed based on a truth-test callback.

Determine if the given chain is entirely composed of objects.

Determine if a job was pushed based on a truth-test callback.

Assert the total count of jobs that were pushed.

Assert that no jobs were pushed.

Get all of the jobs matching a truth-test callback.

Get all of the raw pushes matching a truth-test callback.

Get all of the jobs by listener class, passing an optional truth-test callback.

Determine if there are any stored jobs for a given class.

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.

Map an array of jobs to a collection of inspected jobs.

Get all reserved jobs across every queue.

Get pushed jobs classified by their delay.

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

Push a new job onto the queue.

Push a job onto the fake, or onto the given connection when the job is not faked.

Without a connection, a job that is not faked goes to its own connection, else the default connection.

Determine if a job should be faked or actually dispatched.

Determine if a job should be pushed to the queue instead of faked.

Push a raw payload onto the queue.

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

Push a new job onto the queue.

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

Record the given job as reserved.

Pop the next job off of the queue.

Push an array of jobs onto the queue.

Push an array of jobs onto the fake, or onto the given connection for jobs that are not faked.

Get the jobs that have been pushed.

Get the payloads that were pushed raw.

Specify if jobs should be serialized and restored when being "pushed" to the queue.

Serialize and unserialize the job to simulate the queueing process.

Release the dispatch locks owned by faked jobs.

Clear all of the reserved jobs.

Register a callback to be invoked before pushing a job.

Register a callback to be invoked after pushing a job.

Normalize a queue identifier.

Get the connection name for the queue.

Set the connection name for the queue.