Queue

Robust job processing, backed by modern PostgreSQL and SQLite3.

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

RabbitMQ AMQP Client

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

Idiomatic Elixir client for RabbitMQ.

Apache Kafka Erlang client library

Kafka protocol library for Erlang/Elixir

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

Elixir interface to the Kafka protocol

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

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.

The extension for integrating Ash resources with Oban.

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

Kafka's publisher

erlang simple queue

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

A Broadway producer for an in-memory buffer.

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

A Faktory worker implementation for Elixir

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

Simple Background Job Processing with Mnesia

AMQP 1.0 client

A set of tools for building robust applications with RabbitMQ.

A Jetstream client in pure Elixir.

RabbitMQ connection pool library

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

A Disk Queue for Log Replay in Erlang

Index tree for MQTT topic filters

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

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

erlkaf - Erlang Kafka library based on librdkafka

Fork of the AMQP library with some improvements and facilities

A Redis Stream consumer for Broadway

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.

Elixir RabbitMQ Client

A pure Elixir Client library for Nats.io messaging system

Exq Rate Limiter

Opinionated library for RabbitMQ with exponential backoff retries and RPC.

Verk is a job processing system backed by Redis.

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

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

Non opinionated AMQP helpers

Kafka client for Elixir/Erlang.

Rihanna is a database-backed job queue.

A Plug adapter for Cowboy

Library to increase the throughput of producing messages (coming one at a time) to Kafka by accumulating these messages into batches

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

Membrane Timestamp Queue

Agnostic pub/sub with Redis, RabbitMQ and Postgres support

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

AMQP adapter for Conduit.

Event queue with priority levels

RabbitMQ adapter for Yggdrasil (pub/sub)

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