land/yii2-amqp

Yii2 AMQP extension (wrapper on php-amqplib).

dev-master 2018-12-18 05:22 UTC

Requires

• php: >=7.1
• ext-json: *
• php-amqplib/php-amqplib: ^2.8
• yiisoft/yii2: ^2.0.15

Requires (Dev)

• php-coveralls/php-coveralls: ^2.1
• phpunit/phpunit: ^7.5
• roave/security-advisories: dev-master

Suggests

• ext-pcntl: Use pcntl extension
• ext-posix: Use posix extension

MIT

• Danil Syromolotov

• rabbitmq
• extension
• AMQP
• message queue
• yii2

README

Yii2 AMQP extension

Installation

You need run just this command:

composer require sima-land/yii2-amqp

Configuration

Example configuration:

return [
    'components' => [
        'amqp' => [
            'class' => \simaland\amqp\Component::class,
            'connection' => [
                'dsn' => 'amqp://user:password@host:port/vHost?<param>=<value>'
            ],
            'queues' => [
                [
                    'name' => 'queueName',
                ],
            ],
            'exchanges' => [
                [
                    'name' => 'exchangeName',
                ],
            ],
            'routing' => [
                [
                    'sourceExchange' => 'exchangeName',
                    'targetQueue' => 'queueName',
                ],
            ],
            'consumer' => [
                'callbacks' => [
                    'queueName' => <implement of \simaland\amqp\components\consumer\CallbackInterface::class>,
                ],
            ],
        ],
    ],
];

Testing

You must tests your changes by running this command:

composer test

Example

class AmpqController {

    public function actionSend()
    {
        $msg = \Yii::$app->amqp->createMessage('Test');
        $exchange = \Yii::$app->amqp->exchanges->current();
        $exchange->declare();
        \Yii::$app->amqp->producer->publish($msg, $exchange);
    }

    public function actionListen()
    {
        \Yii::$app->amqp->consumer->declare();
        \Yii::$app->amqp->consumer->consume();
    }