fittinq/symfony-rabbitmq

此包的最新版本(19.1.0)没有提供许可证信息。


README

这有助于创建到RabbitMQ的连接

通过Composer安装

composer require fittinq\symfony-rabbitmq

配置组件

config/bundles.php

<?php

return [
    // ...
    Fittinq\Symfony\RabbitMQ\SymfonyRabbitMQBundle::class => ['all' => true],
];

在您的.env文件中添加以下条目,并根据需要更改

RABBITMQ_HOST=rabbitmq
RABBITMQ_PORT=5672
RABBITMQ_USERNAME=guest
RABBITMQ_PASSWORD=guest

在service.yaml中添加以下条目,这为消费者提供了一个处理单个消息的处理程序,以及一个错误处理程序,如果它无法消费任何消息。

Fittinq\Symfony\Rabbitmq\Command\ConsumeCommand:
    tags:
        - { name: 'console.command', command: 'name:of:command', description: 'description' }
    arguments:
        - Fittinq\Symfony\RabbitMQ\RabbitMQ\RabbitMQ
        - Fittinq\Symfony\RabbitMQ\Handler\Handler
        - Fittinq\Symfony\RabbitMQ\ErrorHandler\ErrorHandler
        - 'queueName'