PHPackages                             antidot-fw/message-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. antidot-fw/message-queue

ActiveLibrary[Queues & Workers](/categories/queues)

antidot-fw/message-queue
========================

Message bus and Pub-Sub integration queues for Antidot Framework.

1.0.0(4y ago)5421[4 PRs](https://github.com/antidot-framework/message-queue/pulls)BSD-2-ClausePHPPHP ^7.4.3|^8.0CI passing

Since Jun 27Pushed 2mo ago1 watchersCompare

[ Source](https://github.com/antidot-framework/message-queue)[ Packagist](https://packagist.org/packages/antidot-fw/message-queue)[ GitHub Sponsors](https://github.com/kpicaza)[ RSS](/packages/antidot-fw-message-queue/feed)WikiDiscussions 1.x.x Synced 3w ago

READMEChangelog (2)Dependencies (17)Versions (10)Used By (0)

Antidot Framework Message Queue
===============================

[](#antidot-framework-message-queue)

[![Scrutinizer Code Quality](https://camo.githubusercontent.com/84cbda4fe321558558a89af5b05743843981b670d2ccba1ff29a3d18bde4c261/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f616e7469646f742d6672616d65776f726b2f6d6573736167652d71756575652f6261646765732f7175616c6974792d73636f72652e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/antidot-framework/message-queue/?branch=master)[![Code Coverage](https://camo.githubusercontent.com/1da1874a7676a2b6577b306cf08b1fe36ff960d9213e609f47d0b94890f32dc8/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f616e7469646f742d6672616d65776f726b2f6d6573736167652d71756575652f6261646765732f636f7665726167652e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/antidot-framework/message-queue/?branch=master)[![Type Coverage](https://camo.githubusercontent.com/82658227f6ff6e7f2b6dd9e0b57996a411c79ff9e03d05ae5c59655c41dcb2f3/68747470733a2f2f73686570686572642e6465762f6769746875622f616e7469646f742d6672616d65776f726b2f6d6573736167652d71756575652f636f7665726167652e737667)](https://shepherd.dev/github/antidot-framework/message-queue)[![Psalm Level](https://camo.githubusercontent.com/a207229c611983c40c6a44ffce5ec6eb2f3ff7e0e74b8ce6a8f108e8d4a9f697/68747470733a2f2f73686570686572642e6465762f6769746875622f616e7469646f742d6672616d65776f726b2f6d6573736167652d71756575652f6c6576656c2e737667)](https://shepherd.dev/github/antidot-framework/message-queue)[![Build Status](https://camo.githubusercontent.com/6cbb14d62b71e707f4e71acf0e08ff7d5a6b78e612fc919b403a4908a23dd577/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f616e7469646f742d6672616d65776f726b2f6d6573736167652d71756575652f6261646765732f6275696c642e706e673f623d6d6173746572)](https://scrutinizer-ci.com/g/antidot-framework/message-queue/build-status/master)[![Code Intelligence Status](https://camo.githubusercontent.com/377239fedeaed4052f225c499453d03dad491c2968f6d1952dbeb3ea0f7c1ef1/68747470733a2f2f7363727574696e697a65722d63692e636f6d2f672f616e7469646f742d6672616d65776f726b2f6d6573736167652d71756575652f6261646765732f636f64652d696e74656c6c6967656e63652e7376673f623d6d6173746572)](https://scrutinizer-ci.com/code-intelligence)

Message queue implementation using [enqueue/enqueue](https://github.com/php-enqueue/enqueue-dev) for Antidot Framework.

```
composer require antidot-fw/message-queue
```

Message Queue
-------------

[](#message-queue)

> A message queue is an asynchronous communication method. It allows storing messages in the queue system until they are consumed and destroyed. Each message is processed only once by a unique consumer.

### Different Queue Systems

[](#different-queue-systems)

- Null Queue
- Filesystem Queue
- DBAL Queue
- Redis Queue
- Beanstalk
- Amazon SQS

Each implementation will have different configuration details, see concrete documentation section. Furthermore, you can use any of [systems implemented in the PHP-enqueue package](https://php-enqueue.github.io/transport), making the needed factories.

### Usage

[](#usage)

You can define as many contexts as you need. You can bind each context to different queues. Once you have created a Context class, you can start sending jobs to the queue. The job should contain the queue name, the message type, and the message itself.

```