Listener
class Listener (View source)
Methods
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. |
Please login to continue.