mugoweb/queue-bundle

Ibexa 的队列系统

维护者

详细信息

github.com/mugoweb/queue-bundle

源代码

问题

安装: 10

依赖项: 0

建议者: 0

安全: 0

星标: 0

关注者: 8

分支: 0

开放问题: 0

类型:symfony-bundle

dev-master 2024-07-08 16:14 UTC

Requires

GPL-2.0-only afeebf28d44f73da97d4a52ac0b0e611978dd664

  • Mugo Web <hi.woop@mugo.ca>

This package is auto-updated.

Last update: 2024-09-08 16:26:35 UTC

README

首先，您需要决定您希望使用哪种传输器。有以下几种选项：https://php-enqueue.github.io/transport 例如，如果您想使用文件系统来存储队列，您需要安装对应的 enqueue 包

composer require enqueue/fs

通过设置环境变量或直接更改配置文件 'config/packages/enqueue.yaml' 来配置传输器

设置 ENQUEUE_DSN 变量为

ENQUEUE_DSN=file

它将在系统临时目录中存储队列。

命令

# To produce messages:
./bin/console mugo:queue:produce <processor>

# To process messages:
./bin/console enqueue:transport:consume <processor>

# To clear queue:
./bin/console mugo:queue:purge <processor>

创建新的队列

创建队列服务类

配置队列服务类

  MugoWeb\QueueBundle\Queue\ExampleProcessor:
    tags:
      - { name: 'enqueue.transport.processor', processor: 'example_processor' }