AMQP Interop ¶

This driver works with RabbitMQ queues.

It requires an amqp interop compatible transport, for example the enqueue/amqp-lib package.

Advantages:

• It works with any amqp interop compatible transports, such as

  • enqueue/amqp-ext based on PHP amqp extension
  • enqueue/amqp-lib based on php-amqplib/php-amqplib
  • enqueue/amqp-bunny based on bunny
• Supports priorities
• Supports delays
• Supports ttr
• Supports attempts
• Contains new options like: vhost, connection_timeout, qos_prefetch_count and so on.
• Supports Secure (SSL) AMQP connections.
• Has the ability to set DSN like: amqp:, amqps: or amqp://user:pass@localhost:1000/vhost

Configuration example:

return [
    'bootstrap' => [
        'queue', // The component registers its own console commands
    ],
    'components' => [
        'queue' => [
            'class' => \yii\queue\amqp_interop\Queue::class,
            'port' => 5672,
            'user' => 'guest',
            'password' => 'guest',
            'queueName' => 'queue',
            'driver' => yii\queue\amqp_interop\Queue::ENQUEUE_AMQP_LIB,

            // or
            'dsn' => 'amqp://guest:guest@localhost:5672/%2F',

            // or, same as above
            'dsn' => 'amqp:',
        ],
    ],
];

Console ¶

A console command is used to execute queued jobs.

yii queue/listen [timeout]

The listen command launches a daemon which infinitely queries the queue. If there are new tasks they're immediately obtained and executed. The timeout parameter specifies the number of seconds to sleep between querying the queue. This method is most efficient when the command is properly daemonized via supervisor or systemd.