Simple REDIS based message queue

1.0.2 2014-03-07 07:40 UTC


Simple REDIS based message queue.



Add the following dependency to your composer.json file:

  "require": {
    // ...
    "sweikenb/redis-mq-bundle": "~1.0"

Active the bundle in your app/AppKernel.php file:

  $bundles = array(
    // ...
    new Sweikenb\Bundle\RedisMQBundle\SweikenbRedisMQBundle(),


As described in the example section, this bundle comes with an default service which uses the default_client connection of the snc redis bundle. If you wish to modify this, you simply can add you own service with an custom client:

    <service id="acme.custom.mq.client" class="%sweikenb_redis_mq.RedisMQService.class%">
      <argument type="service" id="my.custom.snc.redisClient.here"/>

Example usage

You will finde two example commands in this bundle:

  • sweikenb:redismq:example:write
  • sweikenb:redismq:example:read

They will use the default redis client provided by the redis bundle (snc_redis.default_client) and read/wirte some messages into the queue as long as you don't kill the commands (ctrl + c).