phpqueue

Queue system in php

Install

Install via Composer

{
    "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.

require 'vendor/autoload.php';

Example of Publisher

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

use phpqueue\Publisher;

$data = array(
	'name' 		=> 'juan',
	'surname' 	=> 'berzal',
	'email' 	=> '[email protected]'
);

$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

$ php consumer.php

Throw the publiser

$ php publisher.php