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:
<services>
<service id="acme.custom.mq.client" class="%sweikenb_redis_mq.RedisMQService.class%">
<argument type="service" id="my.custom.snc.redisClient.here"/>
</service>
</services>
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
).