Search by

beta / rabbit.client

nnagornyy

RabbitMQ client

Package info

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

Type:lib

pkg:composer/beta/rabbit.client

Security

Advisories: 0

Aikido package health analysis

Transparency log

Statistics

Installs: 4

Dependents: 0

Suggesters: 0

Stars: 0

Open Issues: 0

1.0.1 2024-01-31 08:04 UTC

Requires

Requires (Dev)

None

Suggests

None

Provides

None

Conflicts

None

Replaces

None

MIT d29794b7296b118d7d0cdb251beed6bf0b2f8b89

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

Published on Packagist.org on 2024-01-31 08:04 UTC

This package is auto-updated.

Last update: 2026-08-29 03:05:05 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');