evgmel/php-amqpbus

This library is an implementation of the AMQP Consumer / Publisher wrappers for php-amqplib. It's been tested against RabbitMQ.

php-amqpbus

This library is a wrapper for php-amqplib., _(*1)

You can use Consumer and Publisher/Producer in your projects to process messages from RabbitMQ by AMQP., _(*2)

Supported RabbitMQ Version

This library uses AMQP 0.9.1 by default and thus requires [RabbitMQ 2.0 or later version] (http://www.rabbitmq.com/download.html)., _(*3)

Setup

Add install via composer:, _(*4)

$ composer.phar require "evgmel/php-amqpbus:dev-master"

Publisher and Consumer Usage Example

Before using these examples you should setup RebbitMQ and need to know settings parameters to create instances of consumer and producer., _(*5)

Usage in Silex application:

// publisher.php file

<?php 
use Bus\AMQP\Publisher\MessagePublisherInterface;
require_once __DIR__ . '/../vendor/autoload.php';
/** @var \Silex\Application $app */
$app = require_once(__DIR__ . '/../app/config/bootstrap/app.php');
require_once(__DIR__ . '/../app/config/conf_dev.php');
$app->boot();
/** @var MessagePublisherInterface $publisher */
$publisher = $app['app.bus.amqp.publisher'];
$eventName = $argv[1] ?? 'not_specified_event_name';
$data = isset($argv[2]) ? [$argv[2]] : ['defaultDataKey' => 'defaultDataValue'];
$publisher->publish($eventName, $data);

Run this command:, _(*6)

    php7.1 publisher.php myEventNameHere MyMessageTextHere

After previous command a message with name 'myEventNameHere' will be published to the queue;, _(*7)

 // consumer.php file

 <?php
use Bus\AMQP\Consumer\MessageConsumerInterface;
require_once __DIR__ . '/../vendor/autoload.php';
/** @var \Silex\Application $app */
$app = require_once(__DIR__ . '/../app/config/bootstrap/app.php');
require_once(__DIR__ . '/../app/config/conf_dev.php');
$app->boot();
/** @var MessageConsumerInterface $consumer */
$consumer = $app['app.bus.amqp.consumer'];

register_shutdown_function([$consumer, 'handleError']);

$consumer->consume();

Run this command:, _(*8)

    php7.1 consumer.php 

Consumer will process incoming messages from a queue., _(*9)