cawaphp/queue

This package is abandoned and no longer maintained. No replacement package was suggested.

Сáша Queue

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

Requires

• php: ~7.1
• cawaphp/cawa: dev-master
• cawaphp/console: dev-master
• symfony/debug: ^4.0

Requires (Dev)

• ext-redis: *
• cawaphp/httpclient: dev-master
• php-amqplib/php-amqplib: ^2.6
• phpunit/phpunit: ~7.0

Suggests

• ext-redis: Needed for redis storage
• php-amqplib/php-amqplib: Needed for amqp storage

GPL-3.0-only

• tchiotludo

• redis
• queue
• rabbitmq
• AMQP
• cawa

README

Warning

Be aware that this package is still in heavy developpement. Some breaking change will occure. Thank's for your comprehension.

Features

• Drivers
  • Amqp
  • Redis

Basic Usage

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'));
    }
}

About

License

Cawa is licensed under the GPL v3 License - see the LICENSE file for details