README

Indigo Queue manages your queues and processes the jobs you put onto them.

Install

Via Composer

{
    "require": {
        "indigophp/queue": "@stable"
    }
}

Usage

First of all you have decide which MQ do you want to use. Currently supported MQs:

There is also a special implementation, where to job is not sent to a queue, but executed immediately.

Connector

Connector does the communication between the server and the Queue/Worker class.

Queue

You use the Queue class to push jobs to a queue. You can also push a job with a delay.

See Queue example.

Worker

You usually set up a console application for your workers.

See Worker example.

Job

See examples;

Special connector: DirectConnector

This connector does what you think: Executes the pushed job immediately. You can also push a delayed job, BUT BE CAREFUL: this means that your application will sleep for a certain time, so use it wisely.

Testing

$ codecept run

indigophp / queue

Maintainers

Details