burriko/job-queue

Library to process jobs using Beanstalk.

Job Queue

, _(*1)

Work in progress library to easily push jobs on to a queue so they can be processed outside of the web request. Currently only supports Beanstalk queues. API will break regularly until v1., _(*2)

Usage

Firstly you need to create an instance of a Queue., _(*3)

$pheanstalk = new Pheanstalk\Pheanstalk('localhost');
$queue = new JobQueue\BeanstalkQueue($pheanstalk, 'email_queue');

Creating jobs

You can then push Jobs on to the Queue., _(*4)

$job = new JobQueue\Job('EmailClient', ['client_id' => $id]);
$queue->push($job);

This assumes that you have an EmailClient class with a method named handle that takes an argument of client_id. This will be called later when the job is retrieved from the queue and executed., _(*5)

Processing the queue

This will listen for new jobs to be pushed to the queue, and then execute them., _(*6)

$runner = new JobQueue\JobRunner();
$worker = new JobQueue\QueueWorker($queue, $runner);

$worker->processQueue();

To just process the next job you can do this., _(*7)

$worker->processNextJob();

You can see what the QueueWorker is doing by passing in a logger that implements psr/log., _(*8)

$runner = new JobQueue\JobRunner();
$logger = new Monolog\Logger('queue');
$worker = new JobQueue\QueueWorker($queue, $runner, $logger);