Queue

Robust job processing, backed by modern PostgreSQL and SQLite3.

RabbitMQ AMQP Client

Idiomatic Elixir client for RabbitMQ.

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

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

Apache Kafka Erlang client library

Kafka protocol library for Erlang/Elixir

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

AMQP 1.0 client

ExAws.SQS service package

A SQS connector for Broadway

Fork of the AMQP library with some improvements and facilities

A RabbitMQ connector for Broadway

A Kafka connector for Broadway

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

The extension for integrating Ash resources with Oban.

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

A Google Cloud Pub/Sub connector for Broadway

A simplistic embeddable RPC Client/Server library for AMQP/RabbitMQ.

Elixir interface to the Kafka protocol

Non opinionated AMQP helpers

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.

AMQP RPC Client/Server templates

Kafka's publisher

A Broadway producer for an in-memory buffer.

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

erlang simple queue

Background job processing library for Elixir focused on simplicity

A set of tools for building robust applications with RabbitMQ.

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

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

A library to enqueue jobs with your Active Job job processor. You may want this when strangling your Rails project.

Adaptive backfill library with health checks for Elixir. Supports both single operations and batch processing with sync/async health monitoring.

ActiveMQ client library for Artemis ActiveMQ using STOMP protocol connection. Provides high-level interface for message publishing, consuming, and job scheduling.

AMQPPool maintains a pool of AMQP channels for you to use.

Index tree for MQTT topic filters

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

Pluggable local/clusterable job queue focused on safety.

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

A Jetstream client in pure Elixir.

Simple Background Job Processing with Mnesia

A lightweight Elixir library for managing a pool of AMQP channels using NimblePool.

Declare job workers that can be run by a variety of queuing backends. This plugin is a port of the Rails ActiveJob gem

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

A Redis Stream consumer for Broadway

erlkaf - Erlang Kafka library based on librdkafka

Elixir RabbitMQ Client

A Faktory worker implementation for Elixir

Kafka client for Elixir/Erlang.

Verk is a job processing system backed by Redis.

An AMQP 1.0 connector for Broadway

Exq Rate Limiter

Idiomatic Elixir client for RabbitMQ.

Membrane Timestamp Queue

Rihanna is a database-backed job queue.

Provides convenience methods for subscribing to queues and publishing messages.

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