Libraries tagged by message consumer

An OAuth 1.0 Consumer package to be used for signing OAuth messages

Go to Download

Modify current MultiplyConsumer class from the OldSoundRabbitMqBundle

Go to Download

The simplest way to consume RabbitMQ messages

Go to Download

Standalone messaging library: transactional outbox, deduplication, per-transport producers and consumers (AMQP, Kafka) with retries, DLQ and replay

Go to Download

A simple producer/consumer and RPC message queue on top of Redis and the equally fantastic Predis

Go to Download

Consumer-side deduplication for PHP: the message key is written in the same database transaction as the change it causes, so a redelivered message is skipped. Works with outbox's CloudEvents headers, Symfony Messenger and Laravel Queue.

Go to Download

AMQP module for Slick enabling seamless message exchange with brokers like RabbitMQ through producers and consumers.

Go to Download

Provides a command to scale RabbitMq consumers up when the need arises.

Go to Download

Kafka polling worker infrastructure for Kafka Bus — reads messages from Kafka and dispatches them to the Bus

Go to Download

This library is an implementation of the AMQP Consumer / Publisher wrappers for php-amqplib. It's been tested against RabbitMQ.

Go to Download

Laravel Kafka

Go to Download

Projection engine supporting message consumers that track the point in the event stream

Go to Download

Implements generic message broker consumers and producers in OpenSwoole environment

Go to Download

Process messages with RabbitMQ cli consumer

Go to Download

This library offers an interface for DoSomething.org message broker producers and consumers to report stats.

Go to Download