yjtec/amqp_link

1.0.4 2019-10-18 09:21 UTC

Requires

• php-amqplib/php-amqplib: ^2.10

MIT

• playhan

README

安装

composer require yjtec/amqp_link

php artisan vendor:publis --provider="Yjtec\AmqpLink\ProduceTopicServiceProvider"

使用

生产者

 app('produce')->produceExchanges('key', 'content');

消费者

$callback = function ($msg) {
    echo $msg->body;
};

app('consume')->consumeQueueTopic($callback, 'key', 'queue_name');