phlib/jobqueue

Job Queue implementation.

phlib/jobqueue

, _(*1)

Job Queue implementation., _(*2)

Install

Via Composer, _(*3)

``` bash $ composer require phlib/jobqueue, <sub>(*4)</sub>

or
``` JSON
"require": {
    "phlib/jobqueue": "*"
}

Basic Usage

Bootstrap ``` php $beanstalk = (new \Phlib\Beanstalk\Factory())->create('localhost'); $db = new \Phlib\Db\Adapter(['host' => '127.0.0.1', 'dbname' => 'example']);, <sub>(*5)</sub>

$scheduler = new \Phlib\JobQueue\DbScheduler($db, 300, 600); $jobQueue = new \Phlib\JobQueue\Beanstalk\Scheduled($beanstalk, $scheduler);, <sub>(*6)</sub>

Producer
``` php
$delay = strtotime('+1 week') - time();
$jobQueue->put('my-queue', ['my' => 'jobData'], ['delay' => $delay]);

Consumer ``` php do { while ($job = $jobQueue->retrieve($queue)) { echo "Found new job {$job->getId()}\n", var_export($job->getBody(), true), "\n"; $jobQueue->markAsComplete($job); }, <sub>(*7)</sub>

usleep(500);

} while (true);, <sub>(*8)</sub>

## Jobqueue Script

The script has a dependency on two constructed objects. The Job Queue interface and the Scheduler interface. In order 
to provide this the following describes how they are injected into the script.

jobqueue-config.php (can be located in the root or ```config``` folder.
``` php
<?php

$app = new MyApp();

return new \Phlib\JobQueue\Console\MonitorDependencies($app['jobqueue'], $app['scheduler']);

Table Schema

SQL CREATE TABLE `scheduled_queue` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `tube` varchar(255) NOT NULL DEFAULT 'default', `data` blob NOT NULL, `scheduled_ts` timestamp NULL DEFAULT NULL, `priority` smallint(5) unsigned DEFAULT NULL, `ttr` smallint(5) unsigned DEFAULT NULL, `picked_by` varchar(20) DEFAULT NULL, `picked_ts` timestamp NULL DEFAULT NULL, `create_ts` timestamp NOT NULL, `update_ts` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, PRIMARY KEY (`id`), KEY `scheduled_ts` (`scheduled_ts`) ) ENGINE=InnoDB AUTO_INCREMENT=0 DEFAULT CHARSET=utf8mb4;, <sub>(*9)</sub>

License

This package is free software: you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation, either version 3 of the License, or (at your option) any later version., <sub>(*10)</sub>

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details., <sub>(*11)</sub>

You should have received a copy of the GNU Lesser General Public License along with this program. If not, see http://www.gnu.org/licenses/., <sub>(*12)</sub>