class Listener (View source)
void | __construct(string $commandPath) Create a new queue listener. | |
void | listen(string $connection, string $queue, string $delay, string $memory, int $timeout = 60) Listen to the given queue connection. | |
void | runProcess(Process $process, int $memory) Run the given process. | |
Process | makeProcess(string $connection, string $queue, int $delay, int $memory, int $timeout) Create a new Symfony process for the worker. | |
bool | memoryExceeded(int $memoryLimit) Determine if the memory limit has been exceeded. | |
void | stop() Stop listening and bail out of the script. | |
void | setOutputHandler(Closure $outputHandler) Set the output handler callback. | |
string | getEnvironment() Get the current listener environment. | |
void | setEnvironment(string $environment) Set the current environment. | |
int | getSleep() Get the amount of seconds to wait before polling the queue. | |
void | setSleep(int $sleep) Set the amount of seconds to wait before polling the queue. | |
void | setMaxTries(int $tries) Set the amount of times to try a job before logging it failed. |
Create a new queue listener.
Listen to the given queue connection.
Run the given process.
Create a new Symfony process for the worker.
Determine if the memory limit has been exceeded.
Stop listening and bail out of the script.
Set the output handler callback.
Get the current listener environment.
Set the current environment.
Get the amount of seconds to wait before polling the queue.
Set the amount of seconds to wait before polling the queue.
Set the amount of times to try a job before logging it failed.
© Taylor Otwell
Licensed under the MIT License.
Laravel is a trademark of Taylor Otwell.
https://laravel.com/api/5.3/Illuminate/Queue/Listener.html