twn39 / RabbitMQDelayMessage by twn39

rabbitmq delay message for laravel.
45
1
2
Github Link
Packagist Link
Package Data
Maintainer Username: twn39
Maintainer Contact: twn39@163.com (twn39)
Package Create Date: 2016-12-20
Package Last Update: 2016-12-20
Language: PHP
License: MIT
Last Refreshed: 2025-02-05 03:02:30
Package Statistics
Total Downloads: 45
Monthly Downloads: 0
Daily Downloads: 0
Total Stars: 1
Total Watchers: 2
Total Forks: 0
Total Open Issues: 1

Usage

在config/app.php中加入：

 Wang\RabbitMQ\RabbitMQServiceProvider::class

执行命令：

php artisan vendor:publish

Publish

$delayMessage = app(DelayedMessage::class);

$delayMessage->setExchange('delay-exchange');
$delayMessage->setQueue('delay-queue');

$delayMessage->publish([
    'name' => 'Tang',
    'age' => 22,
], 5000);

return 'success';

Consume


$delayMessage = app(DelayedMessage::class);

$delayMessage->setExchange('delay-exchange');
$delayMessage->setQueue('delay-queue');

$delayMessage->consume(function (AMQPMessage $message) {
    var_dump(json_decode($message->body, true));
});