RabbitMQ

This modules provides RabbitMQ integration with Drupal's queuing system. The module requires the php-amqplib library to run.

Drupal 8 & 9

The Drupal 8 module uses the Queue API to declare and send data to a queue, and it's primary focus is to allow developers to integrate data submission with RabbitMQ.

Queues and exchanges are both supported.

When configured via rabbitmq.config.yml (see the example module), sending data to the queue is as easy as

// Some data to send off to the queue
$data = ['apples', 'oranges'];

// Get the queue config
$queue_factory = \Drupal::service('queue');
$queue = $queue_factory->get('example_queue');

// Send data to the queue
$queue->createItem($data);

Example module

To test RabbitMQ from your Drupal site, enable the rabbitmq_example module and following the instructions from the README.

Drush integration

To test RabbitMQ, the module provides a list of Drush commands to help out with queue processing and queue information.

Version Matrix

Credits

Originally developed by Josh Waihi for Drupal 7 and fgm for the initial Drupal 8 port. Please help out so this module becomes the standard for integration with the Rabbit MQ service.