odolbeau/amqp-service-provider

AMQP Service Provider for Pimple

AMQP Service provider for Pimple

, _(*1)

Installation

The recommended way to install this bundle is through Composer. Require the odolbeau/amqp-service-provider package into your composer.json file:, _(*2)

{
    "require": {
        "odolbeau/amqp-service-provider": "@stable"
    }
}

Protip: you should browse the odolbeau/amqp-service-provider page to choose a stable version to use, avoid the @stable meta constraint., _(*3)

Usage

Register the service provider (see doc for more informations)., _(*4)

use Pimple\Container;
use Bab\Provider\AMQPServiceProvider;

// Create a new container
$container = new Container();

// Add some configuration
$container['amqp.options'] = [
    'connections' => [
        'conn1' => [
            'host' => '127.0.0.1',
            'port' => 5672,
            'login' => 'guest',
            'password' => 'guest',
            'vhost' => '/',
        ],
        'conn2' => [
            'host' => '127.0.0.1',
            'port' => 5672,
            'login' => 'guest',
            'password' => 'guest',
            'vhost' => 'another_vhost',
        ]
    ]
];

// Register the service provider
$container->register(new AMQPServiceProvider());

You can now retrieve queues and / or exchanges like this :, _(*5)

// To get a queue
$container['queue.factory']('queueName', 'conn1');
// To get an exchange
$container['exchange.factory']('queueName', 'conn2');