dimkamonster / laminas-rabbitmq
RabbitMQ module for Laminas
0.2.0
2025-01-21 06:09 UTC
Requires
- php: ~8.2.0
- laminas/laminas-servicemanager: ^3.18
- php-amqplib/php-amqplib: ^3
This package is auto-updated.
Last update: 2025-03-21 06:27:15 UTC
README
Laminas Module for RabbitMQ
Install
composer require dimkamonster/laminas-rabbitmq
Configure
create configuration with rabbitmq
key as described below:
<?php return [ 'rabbitmq' => [ 'host' => 'localhost', 'port' => 5672, 'login' => 'guest', 'password' => 'guest', ], ]
Make sure the module enabled and try an example below.
Send message
<?php /** * @var \RabbitMQ\Service\RabbitMQ $rabbitmqService * @var \Interop\Container\ContainerInterface $container */ $rabbitMQ = $container->get(\RabbitMQ\Service\RabbitMQ::class); $publisher = new \RabbitMQ\Publisher\WorkQueuePublisher('test_work_queue'); $job = new \RabbitMQ\Job\Job(['some' => 'data']); $rabbitMQ->setPublisher($publisher); $rabbitMQ->push($job);
Receive message
<?php /** * @var \RabbitMQ\Service\RabbitMQ $rabbitmqService * @var \Interop\Container\ContainerInterface $container */ $rabbitMQ = $container->get(\RabbitMQ\Service\RabbitMQ::class); $consumer = new \RabbitMQ\Consumer\WorkQueueConsumer('test_work_queue'); $rabbitMQ->setConsumer($consumer); $rabbitMQ->receive(function (\RabbitMQ\Consumer\Message $message) { echo $message->getBody(); $message->ack(); });