README

在 queue client library 中使用 Symfony 项目并带有自己的 Symfony 扩展包，是使用队列客户端库的一种简单方法。

可用命令

• queue-client:add-messages 向队列添加消息
• queue-client:create-queues 创建队列
• queue-client:delete-queues 删除队列
• queue-client:get-messages 从队列获取消息
• queue-client:list-priorities 列出优先级
• queue-client:purge-queues 清空队列
• queue-client:queues-info 显示队列信息

使用 --help 选项查看命令用法。

配置

在 config.yml 中添加队列客户端配置，并使用 Symfony 容器检索服务。

container->get('queue-client')

queue_client 节点需要 adapter 节点来定义要使用的适配器。 adapter 节点必须定义一个 type 参数（见“可用适配器类型”）

然后为每个 type 添加特定的配置。

queue_client:
    adapter:
        type: queue type

示例配置

queue_client:
    queues_file: %kernel.root_dir%/config/queues.yml
    adapter:
        type: file
        repository: /tmp/queues
    priority_handler: 'ReputationVIP\QueueClient\PriorityHandler\ThreeLevelPriorityHandler'

通用配置

• queues_file 指定默认的 队列配置文件。
• queue_prefix 指定可以在 队列配置文件 中使用的队列前缀。
• priority_handler 指定优先级处理器。默认为 ReputationVIP\QueueClient\PriorityHandler\StandardPriorityHandler。

可用适配器类型

• null 黑洞类型。
• memory 内存类型。
• file 文件队列类型。
• sqs SQS 队列类型。

文件类型配置

• repository: 此配置值设置包含队列文件的存储库的绝对路径（默认 /tmp/queues）。

SQS 类型配置

• key: 此配置值设置 SQS 密钥。
• secret: 此配置值设置 SQS 密钥。
• region: 此配置值设置 SQS 区域（默认 eu-west-1）。
• version: 此配置值设置 SQS 版本（默认 2012-11-05）。