diswebru / laravel-rabbitmq
tools for vladimir-yuldashev/laravel-queue-rabbitmq
1.0.0
2025-05-06 06:23 UTC
Requires
- php: >=8.2
- vladimir-yuldashev/laravel-queue-rabbitmq: ^14.2
This package is auto-updated.
Last update: 2025-05-06 06:28:00 UTC
README
Installation
composer require diswebru/laravel-rabbitmq
You need to publish the configuration file using
php artisan vendor:publish --tag=laravel-rabbitmq-config
.env:
RABBITMQ_SSL=false
RABBITMQ_HOST=127.0.0.1
RABBITMQ_PORT=5672
RABBITMQ_USER=guest
RABBITMQ_PASSWORD=guest
Examples
Sending a message to the test topic
use Diswebru\LaravelRabbitMQ\Publish; Publish::setTopic('test')->sent(['message-key' => 'message-value']);
Retrieve unprocessed messages from the test topic
use Diswebru\LaravelRabbitMQ\Consumer; use Diswebru\LaravelRabbitMQ\AMQPMessage; Consumer::setTopic('test')->run(function (AMQPMessage $message) { $data = $message->getJson(); if (!isset($data['message-key']) || $data['message-key'] != 'message-value') { // There will be no commit throw new \Exception('Error message'); } });