README

使用 Enqueue 作为 Prooph Service Bus 的消息生产者。

重要

此库将支持到 2019 年 12 月 31 日，之后将被弃用。

有关更多信息，请参阅官方公告： https://www.sasaprolic.com/2018/08/the-future-of-prooph-components.html

安装

您可以通过执行 $ composer require prooph/psb-enqueue-producer 来通过 composer 安装生产者。

用法

检查 EnqueueMessageProducerTest。设置生产者是一个简单的任务。大部分所需组件都由 PSB 和 Enqueue 提供。此包仅提供让这两个系统协同工作的粘合代码。

为什么选择 Enqueue 生产者

您可以从许多支持的传输中选择一个。
既可以从 Symfony 使用，也可以从纯 PHP 使用。
支持延迟消息（如果传输支持的话）。
支持事件、命令和队列，并且可以获取结果。
简单且干净的代码。

Symfony 配置

如果您使用的是 EnqueueBundle，您可以按照以下方式配置此包中的类

services:
    Prooph\ServiceBus\Message\Enqueue\EnqueueSerializer:
    Prooph\ServiceBus\Message\Enqueue\EnqueueMessageProducer:
        $commandName: 'my_application'
        $replyTimeout: 1000 # Timeout in milliseconds.
    Prooph\ServiceBus\Message\Enqueue\EnqueueMessageProcessor:
        tags:
            - { name: 'enqueue.processor', command: 'my_application' }
            # For enqueue 0.8 use this instead.
            #- { name: 'enqueue.client.processor', topicName: '__command__', processorName: 'my_application' }

然后您可以通过以下方式运行处理器

bin/console enqueue:consume --setup-broker -vvv

有关更多信息，请参阅 Enqueue 文档。

支持

在带有 #prooph 标签的 Stack Overflow 上提问。
在 enqueue gitter 聊天中提出 enqueue 问题。
在 https://github.com/prooph/psb-enqueue-producer/issues 上提交问题。
在 prooph gitter 聊天中说你好。

许可

它是在 MIT 许可证下发布的。

prooph / psb-enqueue-producer

维护者

详细信息

README

重要

安装

用法

为什么选择 Enqueue 生产者

Symfony 配置

支持

许可