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

The extension for integrating Ash resources with Oban.

A Kafka connector for Broadway

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

A Google Cloud Pub/Sub connector for Broadway

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

Elixir interface to the Kafka protocol

Kafka client for Elixir/Erlang.

Kafka's publisher

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

erlang simple queue

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

A Broadway producer for an in-memory buffer.

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

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

AMQP 1.0 client

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 Jetstream client in pure Elixir.

Simple Background Job Processing with Mnesia

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

ExAws.SQS service package (published as beamlab_ex_aws_sqs on Hex). Modernized fork of the archived ex-aws/ex_aws_sqs, using the AWS SQS JSON protocol.

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

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.

Index tree for MQTT topic filters

Fork of the AMQP library with some improvements and facilities

A set of tools for building robust applications with RabbitMQ.

Elixir RabbitMQ Client

Membrane Timestamp Queue

RabbitMQ connection pool library

A powerful, fast, and robust job queue for Elixir backed by Redis

A Redis Stream consumer for Broadway

Rihanna is a database-backed job queue.

erlkaf - Erlang Kafka library based on librdkafka

Pluggable local/clusterable job queue focused on safety.

Transactional outbox for kafka

Forked RabbitMQ connection pool library

A Faktory worker implementation for Elixir

Verk is a job processing system backed by Redis.

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

Opinionated library for RabbitMQ with exponential backoff retries and RPC.

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

Kafka client for Elixir/Erlang.

Exq Rate Limiter

Event queue with priority levels

Non opinionated AMQP helpers

AMQP adapter for Conduit.

A Disk Queue for Log Replay in Erlang

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