chh / kue Goto Github PK

Add an ImmediateQueue queue implementation which calls the job's run method immediately after the job was pushed. This is useful for tests.

Add a separate kue:scheduler command which takes a queue and puts a set of jobs at configured intervals into the queue.

• Use Cron syntax to define intervals or a DSL?
• Sleep until the next job is ready to be scheduled
• Add a class Kue\Scheduler, and a kue:scheduler command which provides a Symfony Console Command and uses the scheduler.

Scheduler API:

$scheduler = new Kue\Scheduler(new Kue\LocalQueue);

$scheduler->every("5m", new HelloWorldJob);

for (;;) {
    # Returns after a job was scheduled, or when the max wait time was reached
    $scheduler->run();
}

Command usage:

$scheduler = new Kue\Scheduler(new Kue\LocalQueue);
$scheduler->every("15m", new ExpensiveStuffJob);

$app = new Symfony\Component\Console\Application;
$app->add(new Kue\Command\Scheduler($scheduler));
$app->run();

When using redis backed queue with multiple workers, none of the forks can reach redis so it ends up dumping "read error on connection"

A solutions for this could be to pass in a factory or closure to create the RedisQueue