Flowpack.JobQueue.RabbitMQ

A job queue backend for the Flowpack.JobQueue.Common package based on RabbitMQ.

Usage

Install the package using composer:

composer require flowpack/jobqueue-rabbitmq

Now the queue can be configured like this:

Flowpack:
  JobQueue:
    Common:
      queues:
        'some-queue':
          className: 'Flowpack\JobQueue\RabbitMQ\RabbitQueue'
          
          executeIsolated: true
          
          options:
            passive: false
            durable: false
            exclusive: false
            autoDelete: false
            
            # optional exchange configuration
            exchange: 
              name: 'elastic_indexing'
              type: 'direct'
              passive: false
              durable: true
              autoDelete: false
              
            client:
              host: localhost
              port: 5672
              username: guest
              password: guest
              vhost: '/'
              
            defaultTimeout: 3.0