PHPackages                             prooph/link-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. prooph/link-message-queue

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

prooph/link-message-queue
=========================

Message Queue Module for prooph LINK

v0.1.0(11y ago)234BSD-3-ClausePHPPHP >=5.5

Since May 10Pushed 11y ago2 watchersCompare

[ Source](https://github.com/prooph/link-message-queue)[ Packagist](https://packagist.org/packages/prooph/link-message-queue)[ Docs](https://github.com/prooph/link-message-queue)[ RSS](/packages/prooph-link-message-queue/feed)WikiDiscussions master Synced 1mo ago

READMEChangelog (1)Dependencies (3)Versions (2)Used By (0)

Prooph\\Link\\MessageQueue
==========================

[](#proophlinkmessagequeue)

Message Queue Module for [prooph LINK](https://github.com/prooph/link)

Bernard Backend
===============

[](#bernard-backend)

This module provides a simple message queue for prooph LINK, so that workflow messages can be handled asynchronous. The message queue is implemented with the help of [bernard](https://github.com/bernardphp/bernard) and the corresponding [message dispatcher](https://github.com/prooph/psb-bernard-dispatcher) implementation for prooph service bus. It uses the DoctrineDriver shipped with bernard and connects to the `prooph.link.app.db` database connection to manage the message queue.

Message Dispatcher
==================

[](#message-dispatcher)

The module provides a ready to use message dispatcher that can be defined in a processing channel to push workflow messages on the queue send over the channel. A channel config using the message dispatcher would look something like this:

```
return [
    'processing' => [
        'channels' => [
            'message_queue' => [
                'targets' => ['Acme\WorkflowMessageHandler'],
                'sender'  => 'a_node_name',
                 'message_dispatcher' => 'prooph.link.message_queue.producer' //ServiceManager alias of the message dispatcher
            ],
            //...
        ],
        //...
    ],
    //...
];
```

Workflow Processor Message Queue
================================

[](#workflow-processor-message-queue)

The [app-core](https://github.com/prooph/link-app-core) module provides the possibility to activate a general message queue for all messages sent by the workflow processor. The message-queue module provides the required implementation. It defines the `\Prooph\Link\Application\Definition::APP_SERVICE_WORKFLOW_PROCESSOR_MESSAGE_QUEUE` as an alias of the `prooph.link.message_queue.producer`so the message dispatcher handles all messages sent by the workflow processor.

Message Consumer
================

[](#message-consumer)

To consume messages pushed to the queue a TickOccurred event needs to be published by the application. You can read about it in the app-core module documentation. The message consumer shipped with the message-queue module listens on this TickOccurred event, performs a bernard consumer tick (pulls the next pending message from the queue) and forwards the message to the processing workflow engine without further routing. The workflow engine is responsible for routing the message to its target.

Support
=======

[](#support)

- Ask any questions on [prooph-users](https://groups.google.com/forum/?hl=de#!forum/prooph) google group.
- File issues at [https://github.com/prooph/link-app-core/issues](https://github.com/prooph/link-message-queue/issues).

Contribution
============

[](#contribution)

You wanna help us? Great! We appreciate any help, be it on implementation level, UI improvements, testing, donation or simply trying out the system and give us feedback. Just leave us a note in our google group linked above and we can discuss further steps.

Thanks, your prooph team

###  Health Score

23

—

LowBetter than 27% of packages

Maintenance20

Infrequent updates — may be unmaintained

Popularity10

Limited adoption so far

Community4

Small or concentrated contributor base

Maturity48

Maturing project, gaining track record

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

Unknown

Total

1

Last Release

4027d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/7341005?v=4)[prooph](/maintainers/prooph)[@prooph](https://github.com/prooph)

---

Tags

modulezf2proophprooph LINK

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/prooph-link-message-queue/health.svg)

```
[![Health](https://phpackages.com/badges/prooph-link-message-queue/health.svg)](https://phpackages.com/packages/prooph-link-message-queue)
```

###  Alternatives

[prooph/event-store-symfony-bundle

109253.5k8](/packages/prooph-event-store-symfony-bundle)[zhuravljov/yii2-queue-monitor

Yii2 Queue Analytics Module

102203.2k](/packages/zhuravljov-yii2-queue-monitor)[thomasvargiu/rabbitmq-module

Integrates php-amqplib with Zend Framework 2 and RabbitMq

15143.0k1](/packages/thomasvargiu-rabbitmq-module)

PHPackages © 2026

[Directory](/)[Categories](/categories)[Trending](/trending)[Changelog](/changelog)[Analyze](/analyze)