diswebru/laravel-rabbitmq

tools for vladimir-yuldashev/laravel-queue-rabbitmq

1.0.0 2025-05-06 06:23 UTC

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