Elixir Queue

Job processing library for Elixir

Concurrent and multi-stage data ingestion and data processing with Elixir.

Robust asynchronous job processor powered by Elixir and modern PostgreSQL.

Verk is a job processing system backed by Redis. It uses the same job definition of Sidekiq/Resque.

Simple Elixir wrapper for the Erlang RabbitMQ client, based on Langohr.

Honeydew is a worker pool library for Elixir.

Kafka client library for Elixir.

Simple Background Job Processing with Mnesia.

enm is an Erlang port driver that wraps the nanomsg C library.

High performance postgres-backed job queue for Elixir.

Simple and reliable background job library for Elixir.

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

background processing application written in Elixir and uses RabbitMQ as a messaging backend.

NSQ client library for Elixir.

An MQTT 3.1.1 client library written in Elixir.

Erlang Priority Queue Implementation.

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

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

Notification dispatch library for Elixir applications

A framework for working with message queues, with adapters for SQS and AMQP, and plugs for reusable messaging patterns.

RabbitMQ bindings and DSL for Elixir.

Cafex is a pure Elixir implementation of Kafka client

RabbitMQ client library, routing keys, RPC over MQ and other stuff.

Simple API for spawning RabbitMQ Producers and Consumers.

Simple implementation of the hungry-consumer model in Elixir.

A blazing fast job processing system backed by GenStage & Redis.

An Elixir client for beanstalkd.

Consumer for Kafka using kafka_ex.

Simple, OTP compliant, Elixir implementation of CSP channels.

Create a data stream across your information systems to query, augment and transform data according to Elixir matching rules.

Elixir client for Disque, an in-memory, distributed job queue.

Priority Queue with multiple backends.

A Heap-based Priority Queue Implementation in Elixir.

A dumb message bus for sharing data between microservices decoupled using Redis.

An Elixir-based ActiveJob Compatible Queueing Library

Library for working with streams.