PHPackages traderinteractive/mongo-queue - 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. traderinteractive/mongo-queue ActiveLibrary[Queues & Workers](/categories/queues) traderinteractive/mongo-queue ============================= Message queue using MongoDB as a backend v4.1.0(2y ago)4617.5k↓25%23[5 issues](https://github.com/traderinteractive/mongo-queue-php/issues)MITPHPPHP ^7.2 || ^8.0 Since Mar 21Pushed 2y ago35 watchersCompare [ Source](https://github.com/traderinteractive/mongo-queue-php)[ Packagist](https://packagist.org/packages/traderinteractive/mongo-queue)[ RSS](/packages/traderinteractive-mongo-queue/feed)WikiDiscussions master Synced 1mo ago READMEChangelog (10)Dependencies (3)Versions (13)Used By (0) mongo-queue-php =============== [](#mongo-queue-php) [![Scrutinizer Code Quality](https://camo.githubusercontent.com/b6dbbaf3358df478b558f31ccdb7862cebc4268d6b596e2ba892f7caa334aac9/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652d7068702f6261646765732f7175616c6974792d73636f72652e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/traderinteractive/mongo-queue-php/?branch=master) [![Latest Stable Version](https://camo.githubusercontent.com/26dcc697cf8235d38dbd42f252e3000bc7d6b46099333eb576d2c61728db9f80/68747470733a2f2f706f7365722e707567782e6f72672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652f762f737461626c65)](https://packagist.org/packages/traderinteractive/mongo-queue)[![Latest Unstable Version](https://camo.githubusercontent.com/b45587c723327cd1fa2a84279be5128b3e4c0596ffc08441ab089e6559da067b/68747470733a2f2f706f7365722e707567782e6f72672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652f762f756e737461626c65)](https://packagist.org/packages/traderinteractive/mongo-queue)[![License](https://camo.githubusercontent.com/082ae8a410886687bfe70c34814df0f2b351b8c30d5b34d1f164ded4ace04097/68747470733a2f2f706f7365722e707567782e6f72672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652f6c6963656e7365)](https://packagist.org/packages/traderinteractive/mongo-queue) [![Total Downloads](https://camo.githubusercontent.com/a27bf9648fab5711f9a79b484373a1638aef7a26c89540a56f2fa6fcce68898b/68747470733a2f2f706f7365722e707567782e6f72672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652f646f776e6c6f616473)](https://packagist.org/packages/traderinteractive/mongo-queue)[![Daily Downloads](https://camo.githubusercontent.com/45a87354ba86175d60e48085c4e3d719efb9b2b02bc5a1fe4eec5979a7721e54/68747470733a2f2f706f7365722e707567782e6f72672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652f642f6461696c79)](https://packagist.org/packages/traderinteractive/mongo-queue)[![Monthly Downloads](https://camo.githubusercontent.com/05ab7ddec0e740ef3a72b4a4a2af7313f246b5d195641c45d03eb8daff23aa02/68747470733a2f2f706f7365722e707567782e6f72672f747261646572696e7465726163746976652f6d6f6e676f2d71756575652f642f6d6f6e74686c79)](https://packagist.org/packages/traderinteractive/mongo-queue) PHP message queue using MongoDB as a backend. Features -------- [](#features) - Message selection and/or count via MongoDB query - Distributes across machines via MongoDB - Message priority - Delayed messages - Running message timeout and redeliver - Atomic acknowledge and send together - Easy index creation based only on payload Simplest use ------------ [](#simplest-use) ``` use TraderInteractive\Mongo\Queue; $queue = new Queue('mongodb://localhost', 'queues', 'queue'); $queue->send(new Message()); $messages = $queue->get([], ['runningResetDuration' => 60]); foreach ($messages as $message) { // Do something with message $queue->ack($message); } ``` Composer -------- [](#composer) To add the library as a local, per-project dependency use [Composer](http://getcomposer.org)! Simply add a dependency on `traderinteractive/mongo-queue` to your project's `composer.json` file such as: ``` composer require traderinteractive/mongo-queue ``` Documentation ------------- [](#documentation) Found in the [source](src/) itself, take a look! Contact ------- [](#contact) Developers may be contacted at: - [Pull Requests](https://github.com/traderinteractive/mongo-queue-php/pulls) - [Issues](https://github.com/traderinteractive/mongo-queue-php/issues) Contributing ------------ [](#contributing) If you would like to contribute, please use our build process for any changes and after the build passes, send us a pull request on github! ``` ./vendor/bin/phpunit ./vendor/bin/phpcs ``` There is also a [docker](http://www.docker.com/)-based [fig](http://www.fig.sh/) configuration that will execute the build inside a docker container. This is an easy way to build the application: ``` fig run build ``` ### Health Score 42 — FairBetter than 90% of packages Maintenance18 Infrequent updates — may be unmaintained Popularity40 Moderate usage in the ecosystem Community23 Small or concentrated contributor base Maturity75 Established project with proven stability Bus Factor1 Top contributor holds 75% of commits — single point of failure 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 ~344 days Recently: every ~494 days Total 12 Last Release 1018d ago Major Versions v1.2.0 → v2.0.12016-08-23 v2.0.4 → v3.0.0-alpha12018-03-07 v3.0.1 → v4.0.02022-10-31 PHP version history (5 changes)v1.0.0PHP >=5.3.2 v1.2.0PHP ~5.4 v2.0.1PHP ^5.6 || ^7.0 v3.0.0-alpha1PHP ^7.0 v4.0.0PHP ^7.2 || ^8.0 ### Community Maintainers ![](https://avatars.githubusercontent.com/u/29952359?v=4)[Trader Interactive](/maintainers/traderinteractive)[@traderinteractive](https://github.com/traderinteractive) --- Top Contributors [![chadicus](https://avatars.githubusercontent.com/u/1182337?v=4)](https://github.com/chadicus "chadicus (81 commits)")[![chrisryan](https://avatars.githubusercontent.com/u/704326?v=4)](https://github.com/chrisryan "chrisryan (13 commits)")[![nubs](https://avatars.githubusercontent.com/u/57673?v=4)](https://github.com/nubs "nubs (12 commits)")[![jncarver](https://avatars.githubusercontent.com/u/6580693?v=4)](https://github.com/jncarver "jncarver (1 commits)")[![raybot](https://avatars.githubusercontent.com/u/1583780?v=4)](https://github.com/raybot "raybot (1 commits)") --- Tags messagequeuemessagingmongopriority ### Code Quality TestsPHPUnit Code StylePHP\_CodeSniffer ### Embed Badge ![Health badge](/badges/traderinteractive-mongo-queue/health.svg) ``` [![Health](https://phpackages.com/badges/traderinteractive-mongo-queue/health.svg)](https://phpackages.com/packages/traderinteractive-mongo-queue) ``` ### Alternatives [php-amqplib/php-amqplib Formerly videlalvaro/php-amqplib. This library is a pure PHP implementation of the AMQP protocol. It's been tested against RabbitMQ. 4.6k125.3M879](/packages/php-amqplib-php-amqplib)[bunny/bunny Performant pure-PHP AMQP (RabbitMQ) non-blocking ReactPHP library 7426.5M37](/packages/bunny-bunny)[php-amqplib/rabbitmq-bundle Integrates php-amqplib with Symfony & RabbitMq. Formerly emag-tech-labs/rabbitmq-bundle, oldsound/rabbitmq-bundle. 1.3k20.1M65](/packages/php-amqplib-rabbitmq-bundle)[queue-interop/queue-interop Promoting the interoperability of MQs objects. Based on Java JMS 48130.5M87](/packages/queue-interop-queue-interop)[enqueue/enqueue-bundle Message Queue Bundle 27615.6M38](/packages/enqueue-enqueue-bundle)[enqueue/enqueue Message Queue Library 19820.0M56](/packages/enqueue-enqueue) PHPackages © 2026 [Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)