Laravel Queue Driver for RabbitMQ

Laravel RabbitMQ is a package by Vladimir Yuldashev that provides a Laravel queue driver for RabbitMQ. Once installed and configured, you can use Laravel’s Queue API. It even provides support for Laravel Horizon out of the box starting with v8.0.

Here are the full queue configuration options available at the time of writing:

  1'connections' => [
  2    // ...
  3    'rabbitmq' => [
  4 
  5        'driver' => 'rabbitmq',
  6 
  7        /*
  8         * Set to "horizon" if you wish to use Laravel Horizon.
  9         */
 10        'worker' => env('RABBITMQ_WORKER', 'default'),
 11 
 12        'dsn' => env('RABBITMQ_DSN', null),
 13 
 14        /*
 15         * Could be one a class that implements \Interop\Amqp\AmqpConnectionFactory for example:
 16         *  - \EnqueueAmqpExt\AmqpConnectionFactory if you install enqueue/amqp-ext
 17         *  - \EnqueueAmqpLib\AmqpConnectionFactory if you install enqueue/amqp-lib
 18         *  - \EnqueueAmqpBunny\AmqpConnectionFactory if you install enqueue/amqp-bunny
 19         */
 20 
 21        'factory_class' => Enqueue\AmqpLib\AmqpConnectionFactory::class,
 22 
 23        'host' => env('RABBITMQ_HOST', '127.0.0.1'),
 24        'port' => env('RABBITMQ_PORT', 5672),
 25 
 26        'vhost' => env('RABBITMQ_VHOST', '/'),
 27        'login' => env('RABBITMQ_LOGIN', 'guest'),
 28        'password' => env('RABBITMQ_PASSWORD', 'guest'),
 29 
 30        'queue' => env('RABBITMQ_QUEUE', 'default'),
 31 
 32        'options' => [
 33 
 34            'exchange' => [
 35 
 36                'name' => env('RABBITMQ_EXCHANGE_NAME'),
 37 
 38                /*
 39                 * Determine if exchange should be created if it does not exist.
 40                 */
 41 
 42                'declare' => env('RABBITMQ_EXCHANGE_DECLARE', true),
 43 
 44                /*
 45                 * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html
 46                 */
 47 
 48                'type' => env('RABBITMQ_EXCHANGE_TYPE', \Interop\Amqp\AmqpTopic::TYPE_DIRECT),
 49                'passive' => env('RABBITMQ_EXCHANGE_PASSIVE', false),
 50                'durable' => env('RABBITMQ_EXCHANGE_DURABLE', true),
 51                'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
 52                'arguments' => env('RABBITMQ_EXCHANGE_ARGUMENTS'),
 53            ],
 54 
 55            'queue' => [
 56 
 57                /*
 58                 * Determine if queue should be created if it does not exist.
 59                 */
 60 
 61                'declare' => env('RABBITMQ_QUEUE_DECLARE', true),
 62 
 63                /*
 64                 * Determine if queue should be binded to the exchange created.
 65                 */
 66 
 67                'bind' => env('RABBITMQ_QUEUE_DECLARE_BIND', true),
 68 
 69                /*
 70                 * Read more about possible values at https://www.rabbitmq.com/tutorials/amqp-concepts.html
 71                 */
 72 
 73                'passive' => env('RABBITMQ_QUEUE_PASSIVE', false),
 74                'durable' => env('RABBITMQ_QUEUE_DURABLE', true),
 75                'exclusive' => env('RABBITMQ_QUEUE_EXCLUSIVE', false),
 76                'auto_delete' => env('RABBITMQ_QUEUE_AUTODELETE', false),
 77                'arguments' => env('RABBITMQ_QUEUE_ARGUMENTS'),
 78            ],
 79        ],
 80 
 81        /*
 82         * Determine the number of seconds to sleep if there's an error communicating with rabbitmq
 83         * If set to false, it'll throw an exception rather than doing the sleep for X seconds.
 84         */
 85 
 86        'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5),
 87 
 88        /*
 89         * Optional SSL params if an SSL connection is used
 90         * 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
 91         */
 92 
 93        'ssl_params' => [
 94            'ssl_on' => env('RABBITMQ_SSL', false),
 95            'cafile' => env('RABBITMQ_SSL_CAFILE', null),
 96            'local_cert' => env('RABBITMQ_SSL_LOCALCERT', null),
 97            'local_key' => env('RABBITMQ_SSL_LOCALKEY', null),
 98            'verify_peer' => env('RABBITMQ_SSL_VERIFY_PEER', true),
 99            'passphrase' => env('RABBITMQ_SSL_PASSPHRASE', null),
100        ],
101 
102    ],
103    // ...
104],

This package is compatible with Laravel and Lumen. It also has some flexibility in the underlying transport library—you can use any ampq interop compatible transport.

You can learn more about this package, get full installation instructions, and view the source code on GitHub at vyuldashev/laravel-queue-rabbitmq.