twn39/rabbitmq-delay-message

为 Laravel 提供的 rabbitmq 延迟消息

维护者

详细信息

github.com/twn39/RabbitMQDelayMessage

源代码

问题

安装: 42

依赖: 0

建议者: 0

安全: 0

星标: 1

关注者: 2

分支: 0

开放问题: 1

1.1.1 2016-12-20 07:39 UTC

Requires

Requires (Dev)

MIT 0b9c6a34f593614481b306c228239141e845f700

  • twn39 <twn39.woop@163.com>

This package is auto-updated.

Last update: 2024-09-21 21:01:39 UTC

README

在 config/app.php 中添加：

 Wang\RabbitMQ\RabbitMQServiceProvider::class

执行命令：

php artisan vendor:publish

发布

$delayMessage = app(DelayedMessage::class);

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

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

return 'success';

消费

$delayMessage = app(DelayedMessage::class);

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

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