Queue

Robust job processing, backed by modern PostgreSQL and SQLite3.

Build concurrent and multi-stage data ingestion and data processing pipelines

Modules shared by rabbitmq-server and rabbitmq-erlang-client

RabbitMQ AMQP Client

Apache Kafka Erlang client library

Kafka protocol library for Erlang/Elixir

Idiomatic Elixir client for RabbitMQ.

ExAws.SQS service package

A SQS connector for Broadway

A RabbitMQ connector for Broadway

A Kafka connector for Broadway

Exq is a job processing library compatible with Resque / Sidekiq for the Elixir language.

A Google Cloud Pub/Sub connector for Broadway

A nats client in pure elixir. Resilience, Performance, Ease-of-Use.

The extension for integrating Ash resources with Oban.

Elixir interface to the Kafka protocol

Kafka client for Elixir/Erlang.

An opinionated Elixir wrapper around brod, the Erlang Kafka client, that supports encrypted connections to Heroku Kafka out of the box.

Exq UI is the UI component for Exq, a job processing library. Exq UI provides the UI dashboard to display stats on job processing.

A Broadway producer for an in-memory buffer.

Kafka's publisher

Modules shared by rabbitmq-amqp1.0 and rabbitmq-amqp1.0-client

AMQP 1.0 client

Set of behaviours meant to be used to create RabbitMQ consumers and publishers.

erlang simple queue

A library for interacting with Google Cloud Pub/Sub (PubSub). Supports both publication and pull subscription

A set of tools for building robust applications with RabbitMQ.

Fork of the AMQP library with some improvements and facilities

An Apache Pulsar client written in Elixir using the Pulsar websocket API.

Index tree for MQTT topic filters

Pluggable local/clusterable job queue focused on safety.

Elsa is a full-featured Kafka library written in Elixir and extending the :brod library with additional support from the :kafka_protocol Erlang libraries to provide capabilities not available in :brod.

RabbitMQ connection pool library

A simple, in-memory queue with worker pooling and rate limiting in Elixir.

Simple Background Job Processing with Mnesia

A Jetstream client in pure Elixir.

A Redis Stream consumer for Broadway

A transactional job queue built with Ecto, PostgreSQL and GenStage.

erlkaf - Erlang Kafka library based on librdkafka

A Faktory worker implementation for Elixir

Elixir RabbitMQ Client

Kafka client for Elixir/Erlang.

Verk is a job processing system backed by Redis.

Exq Rate Limiter

An AMQP 1.0 connector for Broadway

Provides convenience methods for subscribing to queues and publishing messages.

Membrane Timestamp Queue

Rihanna is a database-backed job queue.

A client library for NSQ, `elixir_nsq` aims to be complete, easy to use, and well tested. Developed at Wistia (http://wistia.com).

A Disk Queue for Log Replay in Erlang

Persistent blocking job queue

Non opinionated AMQP helpers

BlockingQueue is a simple queue implemented as a GenServer. It has a fixed maximum length established when it is created.

Easy publishing to many different targets. Supported back-ends: - Rabbit [Amqp](https://hexdocs.pm/amqp/) - Redis [Redix](https://hexdocs.pm/redix) - Http [:httpc](http://erlang.org/doc/man/httpc.html) - Smtp [:gen_smtp](https://hexdocs.pm/gen_smtp) - Slack [Envío](https://hexdocs.pm/envio)

Background processing application/library written in Elixir that uses RabbitMQ as a messaging backend

Robust job queue compatible with Sidekiq Enterprise, powered by GenStage and Redis

Message queue framework, with support for middleware and multiple adapters.

Opinionated library for RabbitMQ with exponential backoff retries and RPC.

библиотеки для работы с ребитом и протоколы

AMQP adapter for Conduit.

GenAMQP is a set of utilities to make microservices using the worker pattern

A general purpose messaging utility library supporting Exq and Kaffe