Laravel AMQP

AMQPMessage SDK for Laravel 8

Installation

Server Requirements

you will need to make sure your server meets the following requirements:

Laravel Installation

composer require mucts/laravel-amqp

Usage

<?php use MuCTSLaravelAMQPFacadesAMQP; use PhpAmqpLibExchangeAMQPExchangeType; // send message AMQP::connection('default') ->setExchange('test') ->setExchangeType(AMQPExchangeType::TOPIC) ->setQueue('test') ->publish('test'); AMQPMessage consumer

use MuCTSLaravelAMQPCommandsAMQPCommand; use PhpAmqpLibMessageAMQPMessage; use IlluminateSupportFacadesLog; use PhpAmqpLibExchangeAMQPExchangeType; class test extends AMQPCommand{ protected string $exchange = 'test'; protected string $queue = 'test'; protected string $exchangeType = AMQPExchangeType::TOPIC; protected string $consumerTag = 'consumer'; protected ?string $connectionName = 'default'; protected bool $autoAsk = false; protected function processMessage(AMQPMessage $message){ Log::info($message->getBody()); // message ask $message->ack(); // message nack $message->nack(true); } }

Configuration

If config/amqp.php not exist, run below:

php artisan vendor:publish