PHPackages tahoelimited/qpush-bundle - PHPackages - PHPackages [Skip to content](#main-content)[PHPackages](/)[Directory](/)[Categories](/categories)[Trending](/trending)[Leaderboard](/leaderboard)[Changelog](/changelog)[Analyze](/analyze)[Collections](/collections)[Log in](/login)[Sign up](/register) 1. [Directory](/) 2. / 3. [Queues & Workers](/categories/queues) 4. / 5. tahoelimited/qpush-bundle ActiveLibrary[Queues & Workers](/categories/queues) tahoelimited/qpush-bundle ========================= Asynchronous processing for Symfony using Push Queues 2.1.0(11y ago)0154Apache 2.0PHPPHP >=5.4.0 Since Feb 5Pushed 11y ago2 watchersCompare [ Source](https://github.com/vmeretail/qpush-bundle)[ Packagist](https://packagist.org/packages/tahoelimited/qpush-bundle)[ Docs](https://github.com/uecode/qpush-bundle)[ RSS](/packages/tahoelimited-qpush-bundle/feed)WikiDiscussions master Synced 1mo ago READMEChangelogDependencies (6)Versions (28)Used By (0) QPush - Symfony2 Push Queue Bundle ================================== [](#qpush---symfony2-push-queue-bundle) [![Build Status](https://camo.githubusercontent.com/d5466ecc0c3962567325e834789d1fa921f91141fb8f443a6ff093af72cc0a2a/68747470733a2f2f696d672e736869656c64732e696f2f7472617669732f7565636f64652f71707573682d62756e646c652f6d61737465722e7376673f7374796c653d666c61742d737175617265)](https://travis-ci.org/uecode/qpush-bundle)[![Quality Score](https://camo.githubusercontent.com/72b678e9e815963feff1e4b17a6d1c0a540b823c56d5b94018463a27cdf6460e/68747470733a2f2f696d672e736869656c64732e696f2f7363727574696e697a65722f672f7565636f64652f71707573682d62756e646c652e7376673f7374796c653d666c61742d737175617265)](https://scrutinizer-ci.com/g/uecode/qpush-bundle/)[![Code Coverage](https://camo.githubusercontent.com/e29f4452a2dad9de711ad00ba4a00edda5c8dc8077c1bb56e3e7d6fb11560d9a/68747470733a2f2f696d672e736869656c64732e696f2f7363727574696e697a65722f636f7665726167652f672f7565636f64652f71707573682d62756e646c652e7376673f7374796c653d666c61742d737175617265)](https://scrutinizer-ci.com/g/uecode/qpush-bundle/)[![Total Downloads](https://camo.githubusercontent.com/606b11f6bd748e3ddd3183c511a171531fd94df3a5a02f6145d6f99c3ce6f837/687474703a2f2f696d672e736869656c64732e696f2f7061636b61676973742f64742f7565636f64652f71707573682d62756e646c652e7376673f7374796c653d666c61742d737175617265)](https://packagist.org/packages/uecode/qpush-bundle) \##Overview This bundle allows you to easily consume messages from Push Queues by simply tagging your services and relying on Symfony's event dispatcher - without needing to run a daemon or background process to continuously poll your queue. **Full Documentation:** [qpush-bundle.readthedocs.org](http://qpush-bundle.rtfd.org) \##Installation The bundle should be installed through composer. \####Add the bundle to your composer.json file ``` { "require": { "uecode/qpush-bundle": "~2.1.0", } } ``` \####Update AppKernel.php of your Symfony Application Add the `UecodeQPushBundle` to your kernel bootstrap sequence, in the `$bundles`array. ``` public function registerBundles() { $bundles = array( // ... new Uecode\Bundle\QPushBundle\UecodeQPushBundle(), ); return $bundles; } ``` \##Basic Configuration: Here is a basic configuration that would create a push queue called `my_queue_name` using AWS or IronMQ. You can read about the supported providers and provider options in the [full documentation](http://qpush-bundle.rtfd.org). \######Example ``` #app/config.yml uecode_qpush: providers: ironmq: token: YOUR_IRON_MQ_TOKEN_HERE project_id: YOUR_IRON_MQ_PROJECT_ID_HERE aws: key: YOUR_AWS_KEY_HERE secret: YOUR_AWS_SECRET_HERE region: YOUR_AWS_REGION_HERE queues: my_queue_key: provider: ironmq #or aws options: queue_name: my_queue_name #optional. the queue name used on the provider push_notifications: true subscribers: - { endpoint: http://example.com/qpush, protocol: http } ``` \##Publishing messages to your Queue Publishing messages is simple - fetch the registered Provider service from the container and call the `publish` method on the respective queue. This bundle stores your messages as a json object and the publish method expects an array, typically associative. \######Example ``` // src/My/Bundle/ExampleBundle/Controller/MyController.php public function publishAction() { $message = ['foo' => 'bar']; // fetch your provider service from the container $this->get('uecode_qpush')->get('my_queue_key')->publish($message); // you can also fetch it directly $this->get('uecode_qpush.my_queue_key')->publish($message); } ``` \##Working with messages from your Queue When a message hits your application, this bundle will dispatch a `MessageEvent`which can be handled by your services. You need to tag your services to handle these events. \######Example ``` services: my_example_service: class: My\Bundle\ExampleBundle\Service\ExampleService tags: - { name: uecode_qpush.event_listener, event: my_queue_key.message_received, method: onMessageReceived } ``` \######Example ``` // src/My/Bundle/ExampleBundle/Service/ExampleService.php use Uecode\Bundle\QPushBundle\Event\MessageEvent; public function onMessageReceived(MessageEvent $event) { $queue_name = $event->getQueueName(); $message = $event->getMessage(); // do some processing } ``` The `Message` objects contain the provider specific message id, a message body, and a collection of provider specific metadata. These properties are accessible through simple getters from the message object. \######Example ``` // src/My/Bundle/ExampleBundle/Service/ExampleService.php use Uecode\Bundle\QPushBundle\Event\MessageEvent; use Uecode\Bundle\QPushBundle\Message\Message; public function onMessageReceived(MessageEvent $event) { $id = $event->getMessage()->getId(); $body = $event->getMessage()->getBody(); $metadata = $event->getMessage()->getMetadata(); // do some processing } ``` \###Cleaning up the Queue Once all other Event Listeners have been invoked on a `MessageEvent`, the Bundle will automatically attempt to remove the Message from your Queue for you. ### Health Score 31 — LowBetter than 68% of packages Maintenance20 Infrequent updates — may be unmaintained Popularity10 Limited adoption so far Community17 Small or concentrated contributor base Maturity68 Established project with proven stability Bus Factor2 2 contributors hold 50%+ of commits How is this calculated?**Maintenance (25%)** — Last commit recency, latest release date, and issue-to-star ratio. Uses a 2-year decay window. **Popularity (30%)** — Total and monthly downloads, GitHub stars, and forks. Logarithmic scaling prevents top-heavy scores. **Community (15%)** — Contributors, dependents, forks, watchers, and maintainers. Measures real ecosystem engagement. **Maturity (30%)** — Project age, version count, PHP version support, and release stability. ### Release Activity Cadence Every ~16 days Recently: every ~27 days Total 26 Last Release 4074d ago Major Versions 0.4.0 → 1.0.02014-02-14 1.4.0 → 2.0.02014-12-17 1.4.1 → 2.0.12015-01-26 ### Community Maintainers ![](https://avatars.githubusercontent.com/u/557390?v=4)[Pablo Maria Martelletti](/maintainers/pmartelletti)[@pmartelletti](https://github.com/pmartelletti) --- Top Contributors [![k-k](https://avatars.githubusercontent.com/u/2430033?v=4)](https://github.com/k-k "k-k (20 commits)")[![cordoval](https://avatars.githubusercontent.com/u/328359?v=4)](https://github.com/cordoval "cordoval (11 commits)")[![jeskew](https://avatars.githubusercontent.com/u/705500?v=4)](https://github.com/jeskew "jeskew (7 commits)")[![cryptiklemur](https://avatars.githubusercontent.com/u/896295?v=4)](https://github.com/cryptiklemur "cryptiklemur (7 commits)")[![eymengunay](https://avatars.githubusercontent.com/u/242627?v=4)](https://github.com/eymengunay "eymengunay (6 commits)")[![stof](https://avatars.githubusercontent.com/u/439401?v=4)](https://github.com/stof "stof (2 commits)")[![jakzal](https://avatars.githubusercontent.com/u/190447?v=4)](https://github.com/jakzal "jakzal (2 commits)")[![pmartelletti](https://avatars.githubusercontent.com/u/557390?v=4)](https://github.com/pmartelletti "pmartelletti (2 commits)")[![sprain](https://avatars.githubusercontent.com/u/260361?v=4)](https://github.com/sprain "sprain (2 commits)")[![sbward](https://avatars.githubusercontent.com/u/470810?v=4)](https://github.com/sbward "sbward (1 commits)")[![pasxel](https://avatars.githubusercontent.com/u/1814849?v=4)](https://github.com/pasxel "pasxel (1 commits)")[![bitdeli-chef](https://avatars.githubusercontent.com/u/3092978?v=4)](https://github.com/bitdeli-chef "bitdeli-chef (1 commits)") --- Tags symfonybundleawspushqpushpub-subasynchiron mq ### Code Quality TestsPHPUnit ### Embed Badge ![Health badge](/badges/tahoelimited-qpush-bundle/health.svg) ``` [![Health](https://phpackages.com/badges/tahoelimited-qpush-bundle/health.svg)](https://phpackages.com/packages/tahoelimited-qpush-bundle) ``` ### Alternatives [uecode/qpush-bundle Asynchronous processing for Symfony using Push Queues 1682.4M2](/packages/uecode-qpush-bundle)[mcfedr/awspushbundle A set of services to simplify using Aws to send push notifications 40378.6k1](/packages/mcfedr-awspushbundle)[prooph/event-store-symfony-bundle 109253.5k8](/packages/prooph-event-store-symfony-bundle)[ufo-tech/json-rpc-bundle The bundle for easy using json-rpc api on your project 224.6k3](/packages/ufo-tech-json-rpc-bundle)[krlove/async-service-call-bundle Symfony bundle for asynchronous service methods calls 1153.6k](/packages/krlove-async-service-call-bundle)[spomky-labs/web-push Web-Push framework for PHP 281.8k](/packages/spomky-labs-web-push) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)