Listener
class Listener (View source)
Properties
| protected string | $commandPath | The command working path. |
|
| protected string | $environment | The environment the workers should run under. |
|
| protected int | $sleep | The amount of seconds to wait before polling the queue. |
|
| protected int | $maxTries | The amount of times to try a job before logging it failed. |
|
| protected string | $workerCommand | The queue worker command line. |
|
| protected Closure|null | $outputHandler | The output handler callback. |
Methods
Create a new queue listener.
Listen to the given queue connection.
Run the given process.
Create a new Symfony process for the worker.
Handle output from the worker process.
Determine if the memory limit has been exceeded.
Stop listening and bail out of the script.
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.
Details
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.
protected void
handleWorkerOutput(int $type, string $line)
Handle output from the worker process.
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.