Download the PHP package opsource/rabbitmq without Composer

RabbitMQ Queue driver Laravel

Installation

You can install this package using this composer:

Configuration

After installation, the package will be published automatically You can find the package configuration file in the path

To use the package, you need to include the following environment variables in your project's ``.env'' file.

RabbitMQ Environment Variables

This section outlines the RabbitMQ environment variables used to configure the connection and behavior of the RabbitMQ client. Optional environment variables that you can use to develop your application

These environment variables help configure the RabbitMQ connection and control various behaviors of the RabbitMQ client.

RabbitMQ Integration Documentation

This document outlines the usage of the RabbitMQManager in your application.

Initialization

First, create an instance of the RabbitMQManager class using the application container:

Alternatively, you can retrieve the RabbitMQ instance directly from the application container using the alias rabbitmq:

Constructor Dependency Injection

To inject the RabbitMQManager into a class using constructor dependency injection, define your class constructor to accept a RabbitMQManager instance:

Getting RabbitMQ Connections

You can retrieve the list of all RabbitMQ connections using the getConnections method provided by the RabbitMQ facade:

Complete Example

Here’s a complete example of how to use RabbitMQManager in a class:

Key Points

• Initialization: You can initialize the RabbitMQManager either directly or through the application container.
• Dependency Injection: Use constructor dependency injection to inject the RabbitMQManager into your classes.
• Connections: Retrieve all RabbitMQ connections using RabbitMQ::getConnections().

This documentation provides a clear and concise explanation of how to use the RabbitMQManager and related functionalities in your application. It covers initialization, dependency injection, and retrieving connections, along with a complete example for better understanding.

RabbitMQ Integration Documentation

This document provides an overview and examples of how to use RabbitMQ for publishing and consuming messages, resolving connections and channels, and configuring the RabbitMQ setup in your application.

Publishing Messages

Single Message Publishing

To publish a single message to the default exchange/topic/queue:

Publish to the default exchange/topic/queue $rabbitMQ->publisher()->publish($message);

Bulk Messages

Publish multiple messages at once:

Consume Messages

Consume through a Closure

Define a handler using a closure to consume messages:

Consume through a Class

Define a handler using a class to consume messages:

Interact with RabbitMQ

Resolve the Default Connection

Get the default connection:

Resolve the Default Channel

Get the default channel:

Configuration

Connection Configuration

Override the default connection configuration:

Message Configuration

Configure the message properties:

Publish Configuration

Configure the publisher and publish a message with specific settings:

Consumer Configuration

Configure the consumer settings:

Example

Running a Consumer

1. Create a Custom Command:

2. Register the Command in app/Console/Kernel.php:

3. Consume through the Handler:

4. Call the Command from the Console:

Publishing Messages

1. Create Route <-> Controller Binding:

2. Create a Controller to Publish Messages:

By following this documentation, you can effectively publish and consume messages using RabbitMQ in your application.

This documentation provides a comprehensive guide on how to set up, configure, publish, and consume messages using RabbitMQ, along with example code and commands for better understanding.

License

The MIT License (MIT). Please see License File for more information.