romeoz/rock-mq

Unified API for message queue services

A message queue API for PHP

, _(*1)

Rock MQ on Packagist, _(*2)

Features

• Background sending
• Pub/Sub
• Non-blocking
• Module for Rock Framework

Installation

From the Command Line:, _(*3)

composer require romeoz/rock-mq:*@dev, _(*4)

In your composer.json:, _(*5)

{
    "require": {
        "romeoz/rock-mq": "*@dev"
    }
}

Quick Start

Run broker:, _(*6)

php tests/data/mq/rabbit/simple_server.php &

Code:, _(*7)

use rock\mq\RabbitQueue;

$rabbit = new RabbitQueue();
$rabbit->send('test'); // result: "Hi! I am server: test"

// or background

$rabbit->sendBackground('test');

Pub/Sub

Run broker:, _(*8)

php tests/data/mq/rabbit/pub_server.php &

Code:, _(*9)

use rock\mq\RabbitQueue;

$rabbit = new RabbitQueue();
$rabbit->blocking = false;
$rabbit->type = 'direct';
$rabbit->exchange = 'direct_test';

$rabbit->subscribe('foo'); // result: "Hi! I am server: foo"

Requirements

• PHP 5.4+
• Gearman should be installed apt-get install libgearman7. Also, should be installed PHP extension apt-get install php5-gearman
• RabbitMQ should be installed apt-get install rabbitmq-server.
• ZeroMQ should be installed apt-get install libzmq3. Also, should be installed PHP extension apt-get install php-zmq

Note: if you have problems with the installation, then see config .travis., _(*10)

License

A message queue API is open-sourced software licensed under the MIT license., _(*11)