void setMaxTries(int $tries) Set the amount of times to try a job before logging it failed. Parameters int $tries Return Value void

void setEnvironment(string $environment) Set the current environment. Parameters string $environment Return Value void

void runProcess(Process $process, int $memory) Run the given process. Parameters Process $process int $memory Return Value void

bool memoryExceeded(int $memoryLimit) Determine if the memory limit has been exceeded. Parameters int $memoryLimit Return Value bool

Process makeProcess(string $connection, string $queue, int $delay, int $memory, int $timeout) Create a new Symfony process for the worker. Parameters string $connection string $queue int $delay int $memory int $timeout Return Value Process

void listen(string $connection, string $queue, string $delay, string $memory, int $timeout = 60) Listen to the given queue connection. Parameters string $connection string $queue string $delay string $memory int $timeout Return Value void

int getSleep() Get the amount of seconds to wait before polling the queue. Return Value int

string getEnvironment() Get the current listener environment. Return Value string

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 memoryExcee

void __construct(Listener $listener) Create a new queue listen command. Parameters Listener $listener Return Value void