enl/amqp-workers

该库提供了更面向对象的方式创建amqp工作进程和生产者

维护者

详细信息

github.com/enl/amqpworkers

主页

源代码

问题

安装: 150

依赖项: 1

建议者: 0

安全: 0

星标: 0

关注者: 2

分支: 1

开放问题: 4

v1.0.0 2016-09-08 09:16 UTC

Requires

Requires (Dev)

MIT License a5de132add3c1415260315913a9825ffe51c43d3

rabbitmqAMQPworkers

This package is auto-updated.

Last update: 2024-08-29 03:47:41 UTC

README

Latest Version on Packagist Software License Build Status Scrutinizer Code Quality Total Downloads

这个库所做的只是提供更流畅的AMQP体验。Original phpamqplib对函数声明的方法非常奇特。

我决定创建一个微小的抽象层，它提供更多灵活的接口

$consumer = Consumer::factory($connection)
    ->withQueue(new Queue('consume_from'))
    ->withWorker($worker)
    ->run();

这是一个非常简短的基本设置，Consumer有很多更多功能。阅读手册以获取更详细的描述。

特性

  • 比原始的php-amqplib库提供更流畅和灵活的接口；
  • 非常懒惰的方法，只有在调用run或produce函数时才会调用与amqp相关的功能。

安装

composer require enl/amqp-workers

用法

// Create AMQPConnection
$connection = new AMQPLazyConnection();

// We're using static `factory` function only for convenience with fluent interface
$consumer = Consumer::factory($connection)
    // set queue definition. all parameters are default
    ->withQueue(new Queue('consume_from'))
    // Worker is an object of WorkerInterface which handles given message body
    ->withWorker($worker)
    // declare and start consuming the queue
    ->run();

变更日志

请参阅变更日志了解最近的变化。

测试

composer test

贡献

请参阅贡献指南和行为准则以获取详细信息。

安全

如果您发现任何安全问题，请通过电子邮件deadyaga@gmail.com联系，而不是使用问题跟踪器。

致谢

许可

MIT许可（MIT）。请参阅许可文件以获取更多信息。