This modules provides RabbitMQ integration with Drupal's queuing system.

This project is under active development, use at your own risk.

The Druapl RabbitMQ modules requires the php-amqplib library to run.
Download the source code from https://github.com/videlalvaro/php-amqplib/tree/v1.0
Extract the source at either sites/all/modules/rabbitmq/php-amqplib or sites/all/libraries/php-amqplib. Rabbit will otherwise fail if it can't find the libraries it needs.

You'll need provide connection credentials in the form of an array using either Drupal's
$conf global variable in settings.php or using variable_set(). E.g.

Option 1. Define in settings.php.

<?php
    global $conf;
    $conf['rabbitmq_credentials'] = array(
      'host' => 'localhost',
      'port' => 5672,
      'username' => 'guest',
      'password' => 'guest',
    );
?>

Option 2. Manually set one time with variable_set().
<?php
    variable_set('rabbitmq_credentials', array(
      'host' => 'localhost',
      'port' => 5672,
      'username' => 'guest',
      'password' => 'guest',
    ));
?>

Set RabbitMQ as the queing system for the queues you want RabbitMQ
to maintain:

<?php
  // Set all queues to use RabbitMQ
  variable_set('queue_default_class', 'RabbitMQQueue');
?>

or
<?php
  // Set a specific queue.
  variable_set('queue_class_<queue_name>', 'RabbitMQQueue');
?>

Project Information

Downloads