visual-craft/work-queue

Work queue using Beanstalk

v0.2.0 2022-06-08 13:30 UTC

Requires

• php: >=7.4.0
• pda/pheanstalk: ^4.0
• psr/log: ^1.0|^2.0|^3.0

Requires (Dev)

• friendsofphp/php-cs-fixer: ^2.18
• kubawerlos/php-cs-fixer-custom-fixers: ^2.4
• phpunit/phpunit: ^9

MIT

README

Simple work queue using Beanstalk

Installation

$ composer require visual-craft/work-queue

Usage

Create the queue manager

use Pheanstalk\Pheanstalk;
use VisualCraft\WorkQueue\Logger;
use VisualCraft\WorkQueue\QueueManager;

$manager = new QueueManager(
    Pheanstalk::create('127.0.0.1', 11300),
    'some_queue',
    new Logger(null)
);

Setup queue processor and worker

use VisualCraft\WorkQueue\QueueProcessor;
use VisualCraft\WorkQueue\Worker\JobMetadata;
use VisualCraft\WorkQueue\Worker\WorkerInterface;

class SomeWorker implements WorkerInterface
{
    public function work($payload, JobMetadata $metadata): void
    {
        // Process job
    }
}

// Create the queue processor and provide it with the worker
$processor = new QueueProcessor(
    $manager,
    new SomeWorker(),
);

// Process the queue
while($processor->process()) {}

Setup job adder and add the job

$adder = new JobAdder($manager);
$id = $adder->add('some data');

License

MIT