Worker
class Worker (View source)
Methods
| void | __construct(QueueManager $manager, Dispatcher $events, ExceptionHandler $exceptions) Create a new queue worker. | |
| void | daemon(string $connectionName, string $queue, WorkerOptions $options) Listen to the given queue in a loop. | |
| void | runNextJob(string $connectionName, string $queue, WorkerOptions $options) Process the next job on the queue. | |
| void | process(string $connectionName, Job $job, WorkerOptions $options) Process a given job from the queue. | |
| bool | memoryExceeded(int $memoryLimit) Determine if the memory limit has been exceeded. | |
| void | stop() Stop listening and bail out of the script. | |
| void | sleep(int $seconds) Sleep the script for a given number of seconds. | |
| void | setCache(Repository $cache) Set the cache repository implementation. | |
| QueueManager | getManager() Get the queue manager instance. | |
| void | setManager(QueueManager $manager) Set the queue manager instance. |
Please login to continue.