class QueueManager implements Factory, Monitor (View source)

Methods

void
__construct(Application $app)

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 $name = null)

Determine if the driver is connected.

connection(string $name = null)

Resolve a queue connection instance.

void
extend(string $driver, Closure $resolver)

Add a queue connection resolver.

void
addConnector(string $driver, Closure $resolver)

Add a queue connection resolver.

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.

string
getQueuePrefix()

Get the queue name prefix.

bool
isDownForMaintenance()

Determine if the application is in maintenance mode.

mixed
__call(string $method, array $parameters)

Dynamically pass calls to the default connection.

Details

at line line 39
void __construct(Application $app)

Create a new queue manager instance.

Parameters

Application $app

Return Value

void

at line line 50
void before(mixed $callback)

Register an event listener for the before job event.

Parameters

mixed $callback

Return Value

void

at line line 61
void after(mixed $callback)

Register an event listener for the after job event.

Parameters

mixed $callback

Return Value

void

at line line 72
void exceptionOccurred(mixed $callback)

Register an event listener for the exception occurred job event.

Parameters

mixed $callback

Return Value

void

at line line 83
void looping(mixed $callback)

Register an event listener for the daemon queue loop.

Parameters

mixed $callback

Return Value

void

at line line 94
void failing(mixed $callback)

Register an event listener for the failed job event.

Parameters

mixed $callback

Return Value

void

at line line 105
void stopping(mixed $callback)

Register an event listener for the daemon queue stopping.

Parameters

mixed $callback

Return Value

void

at line line 116
bool connected(string $name = null)

Determine if the driver is connected.

Parameters

string $name

Return Value

bool

at line line 127
Queue connection(string $name = null)

Resolve a queue connection instance.

Parameters

string $name

Return Value

Queue

at line line 183
void extend(string $driver, Closure $resolver)

Add a queue connection resolver.

Parameters

string $driver
Closure $resolver

Return Value

void

at line line 195
void addConnector(string $driver, Closure $resolver)

Add a queue connection resolver.

Parameters

string $driver
Closure $resolver

Return Value

void

at line line 220
string getDefaultDriver()

Get the name of the default queue connection.

Return Value

string

at line line 231
void setDefaultDriver(string $name)

Set the name of the default queue connection.

Parameters

string $name

Return Value

void

at line line 242
string getName(string $connection = null)

Get the full name for the given connection.

Parameters

string $connection

Return Value

string

at line line 252
string getQueuePrefix()

Get the queue name prefix.

Return Value

string

at line line 262
bool isDownForMaintenance()

Determine if the application is in maintenance mode.

Return Value

bool

at line line 274
mixed __call(string $method, array $parameters)

Dynamically pass calls to the default connection.

Parameters

string $method
array $parameters

Return Value

mixed