QueueManager
class QueueManager implements Factory, Monitor mixin Queue
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
Register an event listener for the before job event.
Register an event listener for the after job event.
Register an event listener for the exception occurred job event.
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.
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
at line 42
void
__construct(Application $app)
Create a new queue manager instance.
at line 53
void
before(mixed $callback)
Register an event listener for the before job event.
at line 64
void
after(mixed $callback)
Register an event listener for the after job event.
at line 75
void
exceptionOccurred(mixed $callback)
Register an event listener for the exception occurred job event.
at line 86
void
looping(mixed $callback)
Register an event listener for the daemon queue loop.
at line 97
void
failing(mixed $callback)
Register an event listener for the failed job event.
at line 108
void
stopping(mixed $callback)
Register an event listener for the daemon queue stopping.
at line 119
bool
connected(string $name = null)
Determine if the driver is connected.
at line 130
Queue
connection(string $name = null)
Resolve a queue connection instance.
at line 152
protected Queue
resolve(string $name)
Resolve a queue connection.
at line 169
protected ConnectorInterface
getConnector(string $driver)
Get the connector for a given driver.
at line 185
void
extend(string $driver, Closure $resolver)
Add a queue connection resolver.
at line 197
void
addConnector(string $driver, Closure $resolver)
Add a queue connection resolver.
at line 208
protected array
getConfig(string $name)
Get the queue connection configuration.
at line 222
string
getDefaultDriver()
Get the name of the default queue connection.
at line 233
void
setDefaultDriver(string $name)
Set the name of the default queue connection.
at line 244
string
getName(string $connection = null)
Get the full name for the given connection.
at line 254
bool
isDownForMaintenance()
Determine if the application is in maintenance mode.
at line 266
mixed
__call(string $method, array $parameters)
Dynamically pass calls to the default connection.