funddy/worker

Worker component

v3.0.0 2015-09-12 13:07 UTC

Requires

• php: >=5.3.3
• predis/predis: ~1.0

Requires (Dev)

• mockery/mockery: 0.7.2
• phpunit/phpunit: 3.7.*

MIT

• Keyvan Akbary

• worker

README

Simple asynchronous worker library based on Redis queues.

Installation

composer require funddy/worker

Usage

Publisher

<?php

require 'vendor/autoload.php';

use Funddy\Worker\WorkerRedisClient\PredisWorkerRedisClient;
use Funddy\Worker\WorkQueue\RedisWorkQueue;
use Predis\Client;

$predisClient = new Client('tcp://localhost');
$redisClient = new PredisWorkerRedisClient($predisClient);
$queue = new RedisWorkQueue('myqueue', $redisClient);

$queue->publish('Hello world!');

Consumer

<?php

require 'vendor/autoload.php';

use Funddy\Worker\WorkerRedisClient\PredisWorkerRedisClient;
use Funddy\Worker\WorkQueue\RedisWorkQueue;
use Predis\Client;

$predisClient = new Client('tcp://localhost');
$redisClient = new PredisWorkerRedisClient($predisClient);
$queue = new RedisWorkQueue('myqueue', $redisClient);

while(true) {
    $message = $queue->consume();//Blocking
    echo $message;
}