PHPackages                             dreanarc/rabbitmq-adapter - PHPackages - PHPackages  [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register)

1. [Directory](/)
2. /
3. [HTTP & Networking](/categories/http)
4. /
5. dreanarc/rabbitmq-adapter

ActiveLibrary[HTTP & Networking](/categories/http)

dreanarc/rabbitmq-adapter
=========================

RabbitMQ Adapter For PHP

v1.0.0(2y ago)08MITPHPPHP ^7.4|^8.0

Since Dec 15Pushed 2y ago1 watchersCompare

[ Source](https://github.com/andre-arc/rabbitmq-adapter)[ Packagist](https://packagist.org/packages/dreanarc/rabbitmq-adapter)[ RSS](/packages/dreanarc-rabbitmq-adapter/feed)WikiDiscussions main Synced yesterday

READMEChangelog (1)Dependencies (1)Versions (2)Used By (0)

RabbitMQ Adapter Package
========================

[](#rabbitmq-adapter-package)

Description of your RabbitMQ adapter package.

Installation
------------

[](#installation)

You can install the package via Composer:

```
composer require dreanarc/rabbitmq-adapter
```

Usage/Examples
--------------

[](#usageexamples)

PHP Native
----------

[](#php-native)

If you're using PHP Native, follow these steps:

- Install composer
- Create PHP Project directory
- Init PHP project using composer
- Install the package via composer ```
    composer require dreanarc/rabbitmq-adapter
    ```
- Code Example for Queue Producer ```
    require 'vendor/autoload.php';

    use Dreanarc\RabbitMQAdapter\RabbitMQProducer;

    $producer = new RabbitMQProducer(
        'localhost',
        '5672',
        'guest',
        'guest'
    );

    $data = "";

    $producer->sendMessage('queue_name', $data);
    ```
- Code Example for Queue Consumer ```
    require 'vendor/autoload.php';

    use Dreanarc\RabbitMQAdapter\RabbitMQConsumer;
    use PhpAmqpLib\Message\AMQPMessage;

    $consumer = new RabbitMQConsumer(
        'localhost',
        '5672',
        'guest',
        'guest'
    );

    $consumer->consume('queue_name', function(AMQPMessage $message){
        echo 'Received message: ', $message->getBody(), PHP_EOL;
    });
    ```

Codeigniter 3.x
---------------

[](#codeigniter-3x)

If you're using Codeigniter 3.x, follow these steps:

- Install the package via composer

    ```
    composer require dreanarc/rabbitmq-adapter
    ```
- create config file *application\\config\\rabbitmq.php*

    ```