Listener

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 listening and bail out of the script.

void

Set the output handler callback.

string

Get the current listener environment.

void

setEnvironment(string $environment)

Set the current environment.

int

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.

Links:

doc_Laravel

2025-01-10 15:47:30

Comments