cawaphp/queue

此包已被弃用，不再维护。没有建议的替代包。

Сáша Queue

维护者

详细信息

github.com/cawaphp/queue

源代码

问题

安装: 179

依赖者: 1

建议者: 0

安全: 0

星标: 0

关注者: 1

分支: 0

开放问题: 1

dev-master 2018-02-19 12:26 UTC

Requires

Requires (Dev)

Suggests

GPL-3.0-only db6848cd4e0f0a56ab8e9d73983edc882f97e1d4

  • tchiotludo

redisqueuerabbitmqAMQPcawa

This package is not auto-updated.

Last update: 2023-12-23 15:38:32 UTC

README

警告

请注意，此包仍在积极开发中。可能会发生一些破坏性更改。感谢您的理解。

功能

  • 驱动程序
    • Amqp
    • Redis

基本用法

use Cawa\Queue\Envelope;
use \Cawa\Queue\QueueFactory;

class Example
{
    use QueueFactory;

    public function consume()
    {
        $queue = self::queue();

        $queue->consume(function (callable $quit, Envelope $envelope = null) {
            if ($envelope) {
                trace($envelope);
            }
            return true;
        });
    }
    
    public function publish()
    {
        $queue = self::queue();
        $queue->publish(new Envelope('publish'));
    }
}

关于

许可协议

Cawa遵循GPL v3许可证 - 有关详细信息，请参阅LICENSE文件。