Skip to content

Latest commit

 

History

History
114 lines (88 loc) · 3.83 KB

amqp.rst

File metadata and controls

114 lines (88 loc) · 3.83 KB

AMQP

Rhubarb currently supports two AMQP connectors:

Note

Note that at this time the ext-amqp extension does not support TLS; for TLS support you will be required to utilize the zircote/amqp package.

zircote/amqp

Configuration

The configuration of the zircote/amqp implementation for Rhubarb is comprised of the following key hierarchy:

  • broker
    • type: the broker class name without the namespace
    • options: the broker specific options
      • exchange: the name of the target exchange
      • queue: an array of options related to the queue
        • name: the queue name
        • arguments: an array of arguments related to the queue, these are AMQP specific and are documented in the zircote/amqp library
      • uri: the amqp server/cluster uri (it should match your celery worker configuration)
  • result_store
    • type: the result_store class name without the namespace
    • options: the result_store specific options
      • exchange: the name of the target exchange
    • uri: the amqp server/cluster uri (it should match your celery worker configuration)

Note

These options SHOULD match your celery worker configuration.

$options = array(
    'broker' => array(
        'type' => 'Amqp',
        'options' => array(
            'exchange' => 'celery',
            'queue' => array(
                'name' => 'celery',
                'arguments' => array(
                    'x-ha-policy' => array('S', 'all')
                )
            ),
            'connection' => 'amqp://guest:guest@localhost:5672/celery'
        )
    ),
    'result_store' => array(
        'type' => 'Amqp',
        'options' => array(
            'exchange' => 'celery',
            'connection' => 'amqp://guest:guest@localhost:5672/celery'
        )
    )
);

$rhubarb = new \Rhubarb\Rhubarb($options);

ext-amqp

Configuration

The configuration of the ext-amqp implementation for Rhubarb is comprised of the following key hierarchy:

  • broker
    • type: the broker class name without the namespace
    • options: the broker specific options
      • exchange: the name of the target exchange
      • queue: an array of options related to the queue
        • name: the queue name
        • arguments: an array of arguments related to the queue, these are AMQP specific
      • uri: the amqp server/cluster uri (it should match your celery worker configuration)
  • result_store
    • type: the result_store class name without the namespace
    • options: the result_store specific options
      • exchange: the name of the target exchange
    • uri: the amqp server/cluster uri (it SHOULD match your celery worker configuration)

Note

These options SHOULD match your celery worker configuration.

$options = array(
    'broker' => array(
        'type' => 'PhpAmqp',
        'options' => array(
            'exchange' => 'celery',
            'queue' => array(
                'arguments' => array(
                )
            ),
            'connection' => 'amqp://guest:guest@localhost:5672/celery'
        )
    ),
    'result_store' => array(
        'type' => 'PhpAmqp',
        'options' => array(
            'exchange' => 'celery',
            'connection' => 'amqp://guest:guest@localhost:5672/celery'
        )
    )
);

$rhubarb = new \Rhubarb\Rhubarb($options);