juanber84/phpqueue

Queue system in php

phpqueue

Queue system in php, _(*1)

Install

Install via Composer, _(*2)

{
    "require": {
        "juanber84/phpqueue": "dev-master"
    }
}

Autoloading

Composer generates a vendor/autoload.php file. You can simply include this file and you will get autoloading for free., _(*3)

require 'vendor/autoload.php';

Example of Publisher

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

use phpqueue\Publisher;

$data = array(
    'name'      => 'juan',
    'surname'   => 'berzal',
    'email'     => 'juanber84@gmail.com'
);

$messages =json_encode($data);

$publisher = new Publisher();
$publisher->setQueue('123456');         
$publisher->setMessage($messages);
$publisher->setBlock_send(true);   // synchronous send
//$publisher->setBlock_send(false);  // asynchronous send
$response = $publisher->publish(); // empty response or array of fails

Example of Consumer

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

use phpqueue\Consumer;

$consumer = new Consumer();
$consumer->setQueue('123456'); 
do {
    echo $consumer->pickup(); 
    // try it out
} while (true);     

Example of Use

• Copy the example of publisher code in publisher.php
• Copy the example of consumer code in consumer.php

Start the consumer, _(*4)

$ php consumer.php

Throw the publiser, _(*5)

$ php publisher.php