Writer

Writer class Writer implements Log, LoggerInterface (View source) Methods void __construct(Logger $monolog, Dispatcher $dispatcher = null) Create a new log writer instance. void emergency(string $message, array $context = array()) Log an emergency message to the logs. void alert(string $message, array $context = array()) Log an alert message to the logs. void critical(string $message, array $context = array()) Log a critical message to the logs. void error(string $mess

Writer::critical()

void critical(string $message, array $context = array()) Log a critical message to the logs. Parameters string $message array $context Return Value void

Worker::__construct()

void __construct(QueueManager $manager, Dispatcher $events, ExceptionHandler $exceptions) Create a new queue worker. Parameters QueueManager $manager Dispatcher $events ExceptionHandler $exceptions Return Value void

WorkerStopping

WorkerStopping class WorkerStopping (View source)

WorkerOptions::__construct()

__construct(int $delay, int $memory = 128, int $timeout = 60, int $sleep = 3, int $maxTries) Create a new worker options instance. Parameters int $delay int $memory int $timeout int $sleep int $maxTries

WorkerOptions

WorkerOptions class WorkerOptions (View source) Properties int $delay The number of seconds before a released job will be available. int $memory The maximum amount of RAM the worker may consume. int $timeout The maximum number of seconds a child worker may run. int $sleep The number of seconds to wait in between polling the queue. int $maxTries The maximum amount of times a job may be attempted.

Worker::stop()

void stop() Stop listening and bail out of the script. Return Value void

Worker::sleep()

void sleep(int $seconds) Sleep the script for a given number of seconds. Parameters int $seconds Return Value void

Worker::runNextJob()

void runNextJob(string $connectionName, string $queue, WorkerOptions $options) Process the next job on the queue. Parameters string $connectionName string $queue WorkerOptions $options Return Value void

Worker::setManager()

void setManager(QueueManager $manager) Set the queue manager instance. Parameters QueueManager $manager Return Value void