backends

redis

Rhubarb supports redis by way of predis/predis

Configuration

Simple Predis Config

<?php
return array(
    'broker' => array('type' => 'predis'),
    'result_store' => array('type' => 'predis'),
    'tasks' => array(array('name' => 'app.add'))
);

Predis supports a number of options listed below:

• scheme [string - default: tcp] [tcp, unix, http]
• host [string - default: 127.0.0.1]
• port [integer - default: 6379]
• path [string - default: not set]
• database [integer - default: not set]
• password [string - default: not set]
• connection_async [boolean - default: false]
• connection_persistent [boolean - default: false]
• connection_timeout [float - default: 5.0]
• read_write_timeout [float - default: not set]
• alias [string - default: not set]
• weight [integer - default: not set]
• iterable_multibulk [boolean - default: false]
• throw_errors [boolean - default: true]

Details on the configuration may be found at https://github.com/nrk/predis/wiki/Connection-Parameters

Example Usage

<?php
return array(
    'broker' => array(
        'connection' => 'tcp://localhost:6379?password=54321'
    ),
    'result_store' => array(
        'connection' => 'tcp://localhost:6370?database=0'
    )
);

AMQP

Rhubarb supports AMQP by way of ext-amqp

Note

Note that at this time the ext-amqp extension does not support TLS

Configuration

Simple AMQP Config

<?php
return array(
    'broker' => array('type' => 'phpamqp'),
    'result_store' => array('type' => 'phpamqp'),
    'tasks' => array(array('name' => 'app.add'))
);

AMQP supports a number of options listed below:

• host [string - default: localhost]
• port [integer - default: 5672]
• vhost [string - default: celery]
• login [string - default: guest]
• password [string - default: guest]
• write_timeout [integer - default: -1]
• read_timeout [integer - default: -1]

These options may be used as an associative array or an URI:

URI string Connection definition

<?php
return array(
    'broker' => array(
        'type' => 'phpamqp',
        'connection' => 'amqp://guest:guest@localhost:5372/celery?read_timeout=5&write_timeout=2'
    ),
    'result_broker' => array(
        'type' => 'phpamqp',
        'connection' => 'amqp://guest:guest@localhost:5372/celery'
    )
);

Array Connection definition

<?php
return array(
    'broker' => array(
        'type' => 'phpamqp',
        'connection' => array(
            'host' => 'localhost',
            'port' => 5372,
            'vhost' => 'celery',
            'login' => 'guest',
            'password' => 'guest',
            'write_timeout' => 5,
            'read_timeout' => 2
        )
    ),
    'result_store' => array(
        'type' => 'phpamqp',
        'connection' => array(
            'host' => 'localhost',
            'port' => 5372,
            'vhost' => 'celery',
            'login' => 'guest',
            'password' => 'guest',
            'write_timeout' => 5,
            'read_timeout' => 2
        )
    ),
);