ajouve/rabbit-mq-wrapper

rabbitMQWrapper 是 RabbitMQ 的包装器

维护者

详细信息

github.com/ajouve/rabbit-mq-wrapper

主页

源代码

问题

安装: 271

依赖项: 0

建议者: 0

安全性: 0

星星: 0

关注者: 2

分支: 0

开放问题: 1

v1.0.8 2016-12-18 22:28 UTC

Requires

Requires (Dev)

MIT 9e68e1318e9f16eb79ac0db711d93759215dda78

frameworkrabbitmqAMQP

This package is not auto-updated.

Last update: 2024-09-14 19:09:27 UTC

README

RabbitMQWrapper 是一个简化 RabbitMQ 使用的库

示例

发送新消息

$client = new \RabbitMQWrapper\Client();
$client->connect();
$client->publish('Message !!', 'exchange_example', 'exchange_example.key');
$client->close();

接收消息

$client = new \RabbitMQWrapper\Client();
$client->connect();
$client->consume('queue_example', 'exchange_example', 'exchange_example.key', function(\RabbitMQWrapper\Message $message) {
    echo $message->getContent() . "\n";
    $message->ack();
});
$client->close();