QueueManager
class QueueManager (View source)
Properties
| protected Application | $app | The application instance. |
|
| protected array | $connections | The array of resolved queue connections. |
Methods
Register an event listener for the daemon queue loop.
Register an event listener for the failed job event.
Register an event listener for the daemon queue stopping.
Determine if the driver is connected.
Resolve a queue connection instance.
Resolve a queue connection.
Get the connector for a given driver.
Get the queue connection configuration.
Get the name of the default queue connection.
Set the name of the default queue connection.
Get the full name for the given connection.
Determine if the application is in maintenance mode.
Dynamically pass calls to the default connection.
Details
void
__construct(Application $app)
Create a new queue manager instance.
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 $name = null)
Determine if the driver is connected.
QueueInterface
connection(string $name = null)
Resolve a queue connection instance.
protected QueueInterface
resolve(string $name)
Resolve a queue connection.
protected ConnectorInterface
getConnector(string $driver)
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
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 $connection = null)
Get the full name for the given connection.
bool
isDownForMaintenance()
Determine if the application is in maintenance mode.
mixed
__call(string $method, array $parameters)
Dynamically pass calls to the default connection.