forseti/simple-queue

There is no license information available for the latest version (1.1.1) of this package.

Gerenciamento de filas simples utlizando o redis

1.1.1 2017-04-19 19:45 UTC

Requires

• predis/predis: ^1.1

Requires (Dev)

• phpunit/phpunit: ^4.8

Unknown License

• Diego Saouda

README

Projeto tem como objetivo a utilização de controle de filas de forma simplificada. Esse projeto foi inspirado no Laravel Queue (illuminate/queue).

Utilizando

Client

<?php
require_once __DIR__ . '/../vendor/autoload.php';

$predis = new Predis\Client();
$queue = (new \Forseti\SimpleQueue\Connection($predis))->queue('queuename');

$job = new \Forseti\SimpleQueue\Job(['data' => 'value']);
$queue->push($job);

Worker

<?php
require_once __DIR__ . '/../vendor/autoload.php';

$predis = new Predis\Client();
$connection = new \Forseti\SimpleQueue\Connection($predis);
$queue = $connection->queue('queuename');

while($job = $queue->pull()) {
    print_r($job);
    sleep(2);

    //remove da fila
    $queue->processed($job);
}

Instalação com Composer

composer require forseti/simple-queue