class
QueueManager implements Factory, Monitor mixin Queue
(View source)
Properties
|
protected Application
|
$app |
The application instance. |
|
|
protected array
|
$connections |
The array of resolved queue connections. |
|
|
protected array
|
$connectors |
The array of resolved queue connectors. |
|
Methods
void
before(mixed $callback)
Register an event listener for the before job event.
void
after(mixed $callback)
Register an event listener for the after job event.
void
exceptionOccurred(mixed $callback)
Register an event listener for the exception occurred job event.
void
looping(mixed $callback)
Register an event listener for the daemon queue loop.
void
failing(mixed $callback)
Register an event listener for the failed job event.
void
stopping(mixed $callback)
Register an event listener for the daemon queue stopping.
bool
connected(string|null $name = null)
Determine if the driver is connected.
connection(string|null $name = null)
Resolve a queue connection instance.
resolve(string $name)
Resolve a queue connection.
getConnector(string $driver)
Get the connector for a given driver.
void
extend(string $driver,
Closure $resolver)
Add a queue connection resolver.
array|null
getConfig(string $name)
Get the queue connection configuration.
string
getName(string|null $connection = null)
Get the full name for the given connection.
mixed
__call(string $method, array $parameters)
Dynamically pass calls to the default connection.
Details
Create a new queue manager instance.
void
before(mixed $callback)
Register an event listener for the before job event.
void
after(mixed $callback)
Register an event listener for the after job event.
void
exceptionOccurred(mixed $callback)
Register an event listener for the exception occurred job event.
void
looping(mixed $callback)
Register an event listener for the daemon queue loop.
void
failing(mixed $callback)
Register an event listener for the failed job event.
void
stopping(mixed $callback)
Register an event listener for the daemon queue stopping.
bool
connected(string|null $name = null)
Determine if the driver is connected.
Queue
connection(string|null $name = null)
Resolve a queue connection instance.
protected Queue
resolve(string $name)
Resolve a queue connection.
Get the connector for a given driver.
void
extend(string $driver, Closure $resolver)
Add a queue connection resolver.
void
addConnector(string $driver, Closure $resolver)
Add a queue connection resolver.
protected array|null
getConfig(string $name)
Get the queue connection configuration.
string
getDefaultDriver()
Get the name of the default queue connection.
void
setDefaultDriver(string $name)
Set the name of the default queue connection.
string
getName(string|null $connection = null)
Get the full name for the given connection.
Get the application instance used by the manager.
Set the application instance used by the manager.
mixed
__call(string $method, array $parameters)
Dynamically pass calls to the default connection.