PHPackages                             hellofresh/reagieren - 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. hellofresh/reagieren

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

hellofresh/reagieren
====================

A set of adapters for message brokers.

v0.6.0(10y ago)41532[1 issues](https://github.com/hellofresh/reagieren/issues)[2 PRs](https://github.com/hellofresh/reagieren/pulls)MITPHPPHP >=5.4.0

Since Mar 29Pushed 5y ago60 watchersCompare

[ Source](https://github.com/hellofresh/reagieren)[ Packagist](https://packagist.org/packages/hellofresh/reagieren)[ Docs](https://github.com/hellofresh/reagieren)[ RSS](/packages/hellofresh-reagieren/feed)WikiDiscussions master Synced 4w ago

READMEChangelog (9)Dependencies (5)Versions (13)Used By (0)

Reagieren
=========

[](#reagieren)

[![Codacy Badge](https://camo.githubusercontent.com/6c3552e926eb8116315bfe564a372e4e7662e60a4328302af58e9da3d10966e5/68747470733a2f2f6170692e636f646163792e636f6d2f70726f6a6563742f62616467652f67726164652f3762313864653538643361643434613238363730636161653833613962613432)](https://www.codacy.com/app/italolelis/reagieren)[![Codacy Badge](https://camo.githubusercontent.com/389b42b002168faba57c0549508b60d60ff13366d075554165b7ae57a334e109/68747470733a2f2f6170692e636f646163792e636f6d2f70726f6a6563742f62616467652f636f7665726167652f3762313864653538643361643434613238363730636161653833613962613432)](https://www.codacy.com/app/italolelis/reagieren)

Reagieren is a set of adapters for many different queues systems.

Currently it's hard to have one unique interface to access RabbitMQ, ApacheKafka, IronMQ, etc... So why not having only one common interface and implementing adapters that follows this interfaces? That's the main concept of this library.

### Where can we use this?

[](#where-can-we-use-this)

Anywhere, that's the beauty of it, you don't depend on a huge framework or any other component. Think about this as a unified way to access message brokers.

### How to use it?

[](#how-to-use-it)

Check this producer:

```
use HelloFresh\Reagieren\MessageBroker\RabbitMQ\PHPAmqp\Producer;

(new Producer('127.0.0.1', 5672, 'guest', 'guest'))->produce('example', 'Hello world this is a message');

echo 'Message sent!', PHP_EOL;
```

Now check this consumer:

```
use HelloFresh\Reagieren\Message;
use HelloFresh\Reagieren\MessageBroker\RabbitMQ\PHPAmqp\Consumer;

$consumer = new Consumer('127.0.0.1', 5672, 'guest', 'guest');

$callback = function (Message $message) {
    echo 'Received ', $message->getPayload(), PHP_EOL;
};

$consumer->consume(
    'example',
    $callback
);

echo 'Listening...', PHP_EOL;
```

As you can see it's just an adapter that will abstract all the complexity of setting technology specific problems. For instance to put something on a kafka queue we need to:

1. Set up the consumer
2. Add brokers
3. Create a topic
4. Select the partition
5. Send the payload

But you don't care about partitions, topics, queue balancing, so that's really awesome!

### Producing to multiple brokers

[](#producing-to-multiple-brokers)

You can produce messages to multiple brokers using `Composite\Producer`, see this example:

```
use HelloFresh\Reagieren\MessageBroker\Composite\Producer;

//... setup RabbitMQ broker
$rabbitProducer = ...;

//... setup Kafka broker
$kafkaBroker = ...;

$configs = [
    'kafka_php' => [
        'topic' => 'example_topic'
    ],
    'rabbit_mq' => [
        'topic' => 'example_exchange'
    ]
];

(new Producer($rabbitProducer, $kafkaBroker))->produce($payload, $configs);

echo 'Message sent!', PHP_EOL;
```

###  Health Score

28

—

LowBetter than 52% of packages

Maintenance15

Infrequent updates — may be unmaintained

Popularity16

Limited adoption so far

Community20

Small or concentrated contributor base

Maturity55

Maturing project, gaining track record

 Bus Factor1

Top contributor holds 56.3% 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 ~2 days

Total

9

Last Release

3724d ago

### Community

Maintainers

![](https://avatars.githubusercontent.com/u/1108049?v=4)[Ítalo Vietro](/maintainers/italolelis)[@italolelis](https://github.com/italolelis)

---

Top Contributors

[![italolelis](https://avatars.githubusercontent.com/u/1108049?v=4)](https://github.com/italolelis "italolelis (40 commits)")[![kieranajp](https://avatars.githubusercontent.com/u/681426?v=4)](https://github.com/kieranajp "kieranajp (25 commits)")[![albertojgomez](https://avatars.githubusercontent.com/u/6017906?v=4)](https://github.com/albertojgomez "albertojgomez (4 commits)")[![nsimaria](https://avatars.githubusercontent.com/u/1467612?v=4)](https://github.com/nsimaria "nsimaria (1 commits)")[![ssola](https://avatars.githubusercontent.com/u/1267434?v=4)](https://github.com/ssola "ssola (1 commits)")

---

Tags

wiz-unknownmessagequeuerabbitmqkafkabroker

###  Code Quality

TestsPHPUnit

### Embed Badge

![Health badge](/badges/hellofresh-reagieren/health.svg)

```
[![Health](https://phpackages.com/badges/hellofresh-reagieren/health.svg)](https://phpackages.com/packages/hellofresh-reagieren)
```

###  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.6k129.9M974](/packages/php-amqplib-php-amqplib)[php-amqplib/rabbitmq-bundle

Integrates php-amqplib with Symfony & RabbitMq. Formerly emag-tech-labs/rabbitmq-bundle, oldsound/rabbitmq-bundle.

1.2k20.7M68](/packages/php-amqplib-rabbitmq-bundle)[bunny/bunny

Performant pure-PHP AMQP (RabbitMQ) non-blocking ReactPHP library

7466.7M42](/packages/bunny-bunny)[pdezwart/php-amqp

PHP AMQP Binding Library

585245.5k2](/packages/pdezwart-php-amqp)[php-amqp/php-amqp

PHP AMQP Binding Library

58510.4k](/packages/php-amqp-php-amqp)[kdyby/rabbitmq

Integrates php-amqplib with RabbitMq and Nette Framework

27715.0k4](/packages/kdyby-rabbitmq)

PHPackages © 2026

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