Listener

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.

doc_Laravel
2016-11-02 16:23:44
Comments
Leave a Comment

Please login to continue.