evgmel/php-amqpbus

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

v1.1.2 2017-05-22 12:56 UTC

Requires

• php: >=7.1.0
• php-amqplib/php-amqplib: 2.6.*
• symfony/event-dispatcher: ~2.8|^3.0
• symfony/monolog-bridge: ~2.8|^3.0

Requires (Dev)

• phpunit/phpunit: ^4.8

MIT

• Evgeny Melnikov

• queue
• rabbitmq
• message
• publisher
• consumer

README

This library is a wrapper for php-amqplib.

You can use Consumer and Publisher/Producer in your projects to process messages from RabbitMQ by AMQP.

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).

Setup

Add install via composer:

$ 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.

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:

    php7.1 publisher.php myEventNameHere MyMessageTextHere

After previous command a message with name 'myEventNameHere' will be published to the queue;

 // 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:

    php7.1 consumer.php 

Consumer will process incoming messages from a queue.