Configuration

app/AppKernel.php

public function registerBundles(){    $bundles = array(        // ...        new Crocos\QueueBundle\CrocosQueueBundle(),    );    // ...}

app/config/config.yml

crocos_queue:    queues:        item_update:            id: myapp.queue.foo            handlers:                - myapp.queue.handler.foo

YourBundle/Resoruces/config/services.yml

services:    myapp.queue.foo:        class: Crocos\QueueBundle\Queue\DoctrineQueue        arguments:            - "table_name_for_foo_queue"            - @doctrine.dbal.default_connection    myapp.queue.handler.foo:        class: Crocos\MyAppBundle\Queue\FooHandler

Create queue table

DROP TABLE IF EXISTS `table_name_for_foo_queue`;CREATE TABLE `table_name_for_foo_queue` (    `id` BIGINT(20) UNSIGNED NOT NULL AUTO_INCREMENT,    `message` VARCHAR(255) NOT NULL,    `priority` TINYINT NOT NULL DEFAULT 10,    PRIMARY KEY (`id`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;

Message queuing

$queue->enqueue($message = 'message', $priority = 10);

$message = $queue->enqueue();

Queue handler

<?phpnamespace Crocos\MyAppBundle\Queue;use Crocos\QueueBundle\Queue\QueueHandlerInterface;class FooHandler implements QueueHandlerInterface{    public function handleMessage($message)    {        // do something you need.    }}

Observe queues

$ cd /path/to/app$ cp src/Crocos/QueueBundle/Resources/skeleton/queue app/queue

$ php app/queue

Available options