beta/rabbit.client

RabbitMQ client

1.0.1 2024-01-31 08:04 UTC

Requires

• php: >=7.4
• beta/mb.client: ^1.0
• php-amqplib/php-amqplib: ^2.0

MIT

• Alexander Nesterov

README

Установка

composer require beta/rabbit.client

Consumer пример работы

use RabbitClient\Client;

$client = Client::initByParams('127.0.0.1', 5672, 'testUser', 'somePassword', 'myVhost');
$message = $client->getMessage('my_topic', ['no_ask' => false]); // запрашиваем 1 сообщение из брокера
$message->getData(); // payload сообщения
$message->getOriginal(); // оригинальное сообщение AMQPMessage
$message->confirm(); // подтверждаем обработку сообщения

/**
* Перебираем новые сообщения из брокера
**/
foreach ($client->getMessageIterator('my_topic') as $message) {
    echo $message->getData();
    $message->confirm();
}

Producer пример работы

use RabbitClient\Client;

$client = Client::initByParams('127.0.0.1', 5672, 'testUser', 'somePassword', 'myVhost');
$client->sendMessage('Test message', 'my_topic');