lightster / hodor
PHP/rabbitmq-based job queue
Requires
- php: >=5.5.18
- davedevelopment/phpmig: ^1.1.0
- hodor/ravens: ~0.0.1
- lightster/yo-pdo: ^0.1.3
- pimple/pimple: ^1.1.1
- symfony/console: ^2.8.3
Requires (Dev)
- codeclimate/php-test-reporter: dev-master
- mikey179/vfsstream: ^1.6.4
- phpunit/phpunit: ^4.8.0
This package is not auto-updated.
Last update: 2021-11-14 18:45:41 UTC
README
A worker queue that is evolving to a job queue
Requirements
- PHP >= 5.5.18
- Composer
- Supervisord
- Postgres >= 9.3
- RabbitMQ
Configuration
Install Hodor in your application via composer:
composer require lightster/hodor:^0.2.0
Create a database on your Postgres server to use with your instance of Hodor:
CREATE DATABASE hodor;
Copy the Hodor distribution config to wherever you keep your application configs:
cp vendor/lightster/hodor/config/dist/config.dist.php config/hodor.php
Update the Postgres and RabbitMQ credentials in your config file.
Write your job runner bootstrap in the job_runner
key of the config
file. The method defined here will be called with the job name and
job params any time a worker receives a job message. This method
should not be more than a few lines—anything more than that should
be offloaded into a bootstrap include script or class. An example
job runner may look like:
<?php return [ 'job_runner' => function($name, $params) { $container = require_once __DIR__ . '/../bootstrap.php'; $job_runner = $container['job_runner']; $job_runner->runJob($name, $params); }, ];
Run the database migrations after your database credentials are setup in your config:
bin/hodor.php database:migrate config/hodor.php
Then setup supervisord to manage your job queue processes:
sudo php bin/hodor.php daemon:generate-config config/hodor.php sudo service supervisord reload
Usage
use Hodor\JobQueue\JobQueue; $job_queue = new JobQueue(); $job_queue->setConfigFile(__DIR__ . '/../../../config/hodor.php'); $job_queue->push( 'Vendor\Project\SomeJob', // job_name ['number' => 123, 'name' => 'Bob'], // job_params ['queue_name' => 'default'] // job_options );