Skip to content

s12v/phpque

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

21 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

Build Status Scrutinizer Code Quality Latest Stable Version

phpque

Lightweight and fast Disque PHP client without external dependencies. Supports PHP 5.3, 5.4, 5.5, 5.6, and HHVM.

Installation

composer require s12v/phpque

Usage

<?php

use Phpque\Client;
use Phpque\Connection\ConnectionException;

require '../vendor/autoload.php';

try {
    // Connect to a server pool
    $client = new Client(['tcp:https://127.0.0.1:7711', 'tcp:https://127.0.0.1:7712']);

    // ... or to a single server
    $client = new Client('tcp:https://127.0.0.1:7711');
} catch (ConnectionException $e) {
    // Handle connection errors
    throw $e;
}

// Add a job with payload "some data" and timeout 1 sec
$client->addJob('test_queue', 'some data', 1000);

// Get a job from the queue
$job = $client->getJob(array('test_queue'));

// Acknowledge the job
$client->ackJob($job);

API

Refer to the Disque documentation and ClientInterface

Development

Run tests:

./vendor/bin/phpunit