PHPackages                             mostafaabdelbaset/laravel-queue-rabbitmq - 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. [Queues & Workers](/categories/queues)
4. /
5. mostafaabdelbaset/laravel-queue-rabbitmq

ActiveLibrary[Queues & Workers](/categories/queues)

mostafaabdelbaset/laravel-queue-rabbitmq
========================================

RabbitMQ driver for Laravel Queue

v7.1.5(7y ago)03.9kMITPHPPHP ^7.1.3

Since Jan 28Pushed 7y ago2 watchersCompare

[ Source](https://github.com/mostafaabdelbaset/laravel-queue-rabbitmq)[ Packagist](https://packagist.org/packages/mostafaabdelbaset/laravel-queue-rabbitmq)[ RSS](/packages/mostafaabdelbaset-laravel-queue-rabbitmq/feed)WikiDiscussions master Synced today

READMEChangelog (3)Dependencies (8)Versions (31)Used By (0)

RabbitMQ Queue driver for Laravel
=================================

[](#rabbitmq-queue-driver-for-laravel)

[![Latest Stable Version](https://camo.githubusercontent.com/ae35fda6d3cb5b57b8d37357c6952383168d3700e346429ed5246210f4b05a48/68747470733a2f2f706f7365722e707567782e6f72672f766c6164696d69722d79756c6461736865762f6c61726176656c2d71756575652d7261626269746d712f762f737461626c653f666f726d61743d666c61742d737175617265)](https://packagist.org/packages/vladimir-yuldashev/laravel-queue-rabbitmq)[![Build Status](https://camo.githubusercontent.com/cd7fa6cf0c5d6c472d47c0b7df543cf1822efe48646f8d1e5748841756fce62b/68747470733a2f2f696d672e736869656c64732e696f2f7472617669732f7679756c6461736865762f6c61726176656c2d71756575652d7261626269746d712e7376673f7374796c653d666c61742d737175617265)](https://travis-ci.org/vyuldashev/laravel-queue-rabbitmq)[![Total Downloads](https://camo.githubusercontent.com/f38a16fd27cfaa1a90e2c6bca3d4b04a9e5d73abb89d388dabc6e4c86354c4bc/68747470733a2f2f706f7365722e707567782e6f72672f766c6164696d69722d79756c6461736865762f6c61726176656c2d71756575652d7261626269746d712f646f776e6c6f6164733f666f726d61743d666c61742d737175617265)](https://packagist.org/packages/vladimir-yuldashev/laravel-queue-rabbitmq)[![StyleCI](https://camo.githubusercontent.com/f60d931ca9314100ec128218fd0d3600c6dcc6517471a84b280d9b4fd511dcbc/68747470733a2f2f7374796c6563692e696f2f7265706f732f31343937363735322f736869656c64)](https://styleci.io/repos/14976752)[![License](https://camo.githubusercontent.com/5d5fd5b6ae3ea751391bfefbbb234e670205414b1ec2a8e06f789a9ee277ea6b/68747470733a2f2f706f7365722e707567782e6f72672f766c6164696d69722d79756c6461736865762f6c61726176656c2d71756575652d7261626269746d712f6c6963656e73653f666f726d61743d666c61742d737175617265)](https://packagist.org/packages/vladimir-yuldashev/laravel-queue-rabbitmq)

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

[](#installation)

You can install this package via composer using this command:

```
composer require mostafaabdelbaset/laravel-queue-rabbitmq

```

The package will automatically register itself using Laravel auto-discovery.

Setup connection in `config/queue.php`

```
'connections' => [
    // ...
    'rabbitmq' => [

        'driver' => 'rabbitmq',

        'dsn' => env('RABBITMQ_DSN', null),

        /*
         * Could be one a class that implements \Interop\Amqp\AmqpConnectionFactory for example:
         *  - \EnqueueAmqpExt\AmqpConnectionFactory if you install enqueue/amqp-ext
         *  - \EnqueueAmqpLib\AmqpConnectionFactory if you install enqueue/amqp-lib
         *  - \EnqueueAmqpBunny\AmqpConnectionFactory if you install enqueue/amqp-bunny
         */

        'factory_class' => Enqueue\AmqpLib\AmqpConnectionFactory::class,

        'host' => env('RABBITMQ_HOST', '127.0.0.1'),
        'port' => env('RABBITMQ_PORT', 5672),

        'vhost' => env('RABBITMQ_VHOST', '/'),
        'login' => env('RABBITMQ_LOGIN', 'guest'),
        'password' => env('RABBITMQ_PASSWORD', 'guest'),

        'queue' => env('RABBITMQ_QUEUE', 'default'),

        'options' => [

            'exchange' => [

                'name' => env('RABBITMQ_EXCHANGE_NAME'),

                /*
                 * Determine if exchange should be created if it does not exist.
                 */

                'declare' => env('RABBITMQ_EXCHANGE_DECLARE', true),

                /*
                 * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html
                 */

                'type' => env('RABBITMQ_EXCHANGE_TYPE', \Interop\Amqp\AmqpTopic::TYPE_DIRECT),
                'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
                'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true),
                'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
                'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'),
            ],

            'queue' => [

                /*
                 * Determine if queue should be created if it does not exist.
                 */

                'declare' => env('RABBITMQ_QUEUE_DECLARE', true),

                /*
                 * Determine if queue should be binded to the exchange created.
                 */

                'bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true),

                /*
                 * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html
                 */

                'passive' => env('RABBITMQ_QUEUE_PASSIVE', false),
                'durable' => env('RABBITMQ_QUEUE_DURABLE', true),
                'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
                'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
                'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'),
            ],
        ],

        /*
         * Determine the number of seconds to sleep if there's an error communicating with rabbitmq
         * If set to false, it'll throw an exception rather than doing the sleep for X seconds.
         */

        'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5),

        /*
         * Optional SSL params if an SSL connection is used
         * Using an SSL connection will also require to configure your RabbitMQ to enable SSL. More details can be founds here: https://www.rabbitmq.com/ssl.html
         */

        'ssl_params' => [
            'ssl_on' => env('RABBITMQ_SSL', false),
            'cafile' => env('RABBITMQ_SSL_CAFILE', null),
            'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),
            'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),
            'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),
            'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),
        ],

    ],
    // ...
],
```

Usage
-----

[](#usage)

Once you completed the configuration you can use Laravel Queue API. If you used other queue drivers you do not need to change anything else. If you do not know how to use Queue API, please refer to the official Laravel documentation:

Using other AMQP transports
---------------------------

[](#using-other-amqp-transports)

The package uses [enqueue/amqp-lib](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/transport/amqp_lib.md) transport which is based on [php-amqplib](https://github.com/php-amqplib/php-amqplib). There is possibility to use any [amqp interop](https://github.com/queue-interop/queue-interop#amqp-interop) compatible transport, for example `enqueue/amqp-ext` or `enqueue/amqp-bunny`. Here's an example on how one can change the transport to `enqueue/amqp-bunny`.

First, install desired transport package:

```
composer require enqueue/amqp-bunny:^0.8
```

Change the factory class in `config/queue.php`:

```
    // ...
    'connections' => [
        'rabbitmq' => [
            'driver' => 'rabbitmq',
            'factory_class' => Enqueue\AmqpBunny\AmqpConnectionFactory::class,
        ],
    ],
```

Testing
-------

[](#testing)

You can run the tests with:

```
vendor/bin/phpunit
```

Contribution
------------

[](#contribution)

You can contribute to this package by discovering bugs and opening issues. Please, add to which version of package you create pull request or issue. (e.g. \[5.2\] Fatal error on delayed job)

###  Health Score

34

—

LowBetter than 77% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity18

Limited adoption so far

Community20

Small or concentrated contributor base

Maturity69

Established project with proven stability

 Bus Factor1

Top contributor holds 78.2% of commits — single point of failure

How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window.

**Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores.

**Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement.

**Maturity (30%)** — Project age, version count, PHP version support, and release stability.

###  Release Activity

Cadence

Every ~65 days

Recently: every ~49 days

Total

30

Last Release

2602d ago

Major Versions

4.1 → v5.0.x-dev2016-03-14

4.2 → v5.5.x-dev2017-09-06

5.5 → v6.0.02017-11-12

v6.0.x-dev → v7.0.02018-02-11

PHP version history (6 changes)4.0PHP >=5.3.0

v5.0.x-devPHP >=5.4.0

v5.2.x-devPHP >=5.5.9

5.3PHP >=5.6.4

v5.5.x-devPHP >=7.0

v7.1.0PHP ^7.1.3

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/8994754?v=4)[Mostafa Abdel Baset](/maintainers/mostafaabdelbaset)[@mostafaabdelbaset](https://github.com/mostafaabdelbaset)

---

Top Contributors

[![vyuldashev](https://avatars.githubusercontent.com/u/1809081?v=4)](https://github.com/vyuldashev "vyuldashev (208 commits)")[![makasim](https://avatars.githubusercontent.com/u/143206?v=4)](https://github.com/makasim "makasim (23 commits)")[![dustindoiron](https://avatars.githubusercontent.com/u/857244?v=4)](https://github.com/dustindoiron "dustindoiron (6 commits)")[![nicksnellockts](https://avatars.githubusercontent.com/u/15774335?v=4)](https://github.com/nicksnellockts "nicksnellockts (3 commits)")[![jlozano254](https://avatars.githubusercontent.com/u/8600559?v=4)](https://github.com/jlozano254 "jlozano254 (3 commits)")[![jinchan-ck](https://avatars.githubusercontent.com/u/3828494?v=4)](https://github.com/jinchan-ck "jinchan-ck (2 commits)")[![eupathy](https://avatars.githubusercontent.com/u/6639227?v=4)](https://github.com/eupathy "eupathy (2 commits)")[![AaronJan](https://avatars.githubusercontent.com/u/4630940?v=4)](https://github.com/AaronJan "AaronJan (2 commits)")[![net53](https://avatars.githubusercontent.com/u/34511399?v=4)](https://github.com/net53 "net53 (2 commits)")[![vrubim](https://avatars.githubusercontent.com/u/127127950?v=4)](https://github.com/vrubim "vrubim (2 commits)")[![jakubkratina](https://avatars.githubusercontent.com/u/712021?v=4)](https://github.com/jakubkratina "jakubkratina (1 commits)")[![vladkucherov](https://avatars.githubusercontent.com/u/4151984?v=4)](https://github.com/vladkucherov "vladkucherov (1 commits)")[![ConnorVG](https://avatars.githubusercontent.com/u/3260091?v=4)](https://github.com/ConnorVG "ConnorVG (1 commits)")[![jowy](https://avatars.githubusercontent.com/u/391324?v=4)](https://github.com/jowy "jowy (1 commits)")[![clanth](https://avatars.githubusercontent.com/u/17596953?v=4)](https://github.com/clanth "clanth (1 commits)")[![mikanoz](https://avatars.githubusercontent.com/u/2713277?v=4)](https://github.com/mikanoz "mikanoz (1 commits)")[![mintopia](https://avatars.githubusercontent.com/u/105940?v=4)](https://github.com/mintopia "mintopia (1 commits)")[![akeinhell](https://avatars.githubusercontent.com/u/1063877?v=4)](https://github.com/akeinhell "akeinhell (1 commits)")[![amirrf](https://avatars.githubusercontent.com/u/7165132?v=4)](https://github.com/amirrf "amirrf (1 commits)")[![elvenpath](https://avatars.githubusercontent.com/u/1319068?v=4)](https://github.com/elvenpath "elvenpath (1 commits)")

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/mostafaabdelbaset-laravel-queue-rabbitmq/health.svg)

```
[![Health](https://phpackages.com/badges/mostafaabdelbaset-laravel-queue-rabbitmq/health.svg)](https://phpackages.com/packages/mostafaabdelbaset-laravel-queue-rabbitmq)
```

###  Alternatives

[illuminate/queue

The Illuminate Queue package.

20331.4M1.2k](/packages/illuminate-queue)[palpalani/laravel-sqs-queue-json-reader

Custom SQS queue reader for Laravel

26109.8k](/packages/palpalani-laravel-sqs-queue-json-reader)[rapidez/core

Rapidez Core

1820.7k53](/packages/rapidez-core)[aedart/athenaeum

Athenaeum is a mono repository; a collection of various PHP packages

255.2k](/packages/aedart-athenaeum)[aplr/kafkaesk

Laravel Kafka queue driver

102.1k](/packages/aplr-kafkaesk)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)