beta/rabbit.client

RabbitMQ client

Maintainers

Details

github.com/beta-eto-code/rabbit.client

Source

Issues

Installs: 1

Dependents: 0

Suggesters: 0

Security: 0

Stars: 0

Watchers: 2

Forks: 0

Open Issues: 0

Type:lib

1.0.1 2024-01-31 08:04 UTC

Requires

MIT d29794b7296b118d7d0cdb251beed6bf0b2f8b89

  • Alexander Nesterov <alex19pov31.woop@gmail.com>

This package is auto-updated.

Last update: 2025-03-29 01:08:12 UTC

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');