mcfedr/doctrine-delay-queue-driver-bundle

A bundle for running symfony background tasks with doctrine as the driver

Doctrine Delay Queue Driver Bundle

A driver for Queue Manager Bundle that uses Doctrine to store delayed jobs, _(*1)

This driver doesn't run jobs, it requires another driver to actually process jobs., _(*2)

It currently only works with MySQL as a native query is required to find jobs in a concurrency safe way., _(*3)

, _(*4)

Usage

You should run the daemon for delay in addition to any other daemons you are using. This runner simply moves jobs from Doctrine into your other job queues. Because its not doing much work generally a single instance can cope with a high number of jobs., _(*5)

./bin/console mcfedr:queue:{name}-runner

Where {name} is what you used in the config. Add -v or more to get detailed logs., _(*6)

Install

Composer

composer require mcfedr/doctrine-delay-queue-driver-bundle

AppKernel

Include the bundle in your AppKernel, _(*7)

public function registerBundles()
{
    $bundles = [
        ...
        new Mcfedr\QueueManagerBundle\McfedrQueueManagerBundle(),
        new Mcfedr\DoctrineDelayQueueDriverBundle\McfedrDoctrineDelayQueueDriverBundle(),

Config

With this bundle installed you can setup your queue manager config similar to this:, _(*8)

mcfedr_queue_manager:
    managers:
        delay:
            driver: doctrine_delay
            options:
                entity_manager: default
                default_manager: default
                default_manager_options: []

This will create a QueueManager service named "mcfedr_queue_manager.delay", _(*9)

• entity_manager - Doctrine entity manager to use
• default_manager - Default job processor
• default_manager_options - Default options to pass to job processor put

Options to QueueManager::put

• time - A \DateTime object of when to schedule this job
• delay - Number of seconds from now to schedule this job
• manager - Use a different job processor for this job
• manager_options - Options to pass to the processors put method

Note

If delay or time option is less then 30 seconds the job will be scheduled for immediate execution, _(*10)

Tables

After you have installed you will need to do a schema update so that the table of delayed tasks is created, _(*11)