API Reference hare_mq v#1.4.0

HareMq is an Elixir library for interacting with AMQP systems such as RabbitMQ. It provides supervised connection management, queue/exchange topology declaration, message publishing with optional deduplication, message consumption with automatic retry/dead-letter routing, stream queue support, and dynamic consumer scaling with an optional auto-scaler.

A GenServer that automatically scales the number of consumers based on the number of messages in the RabbitMQ queue.

Configuration module for HareMq AutoScaler.

Runtime configuration struct and builder for HareMq queue consumers.

GenServer that manages a single AMQP connection.

Macro that injects a single-process RabbitMQ consumer GenServer.

ETS-backed deduplication cache for RabbitMQ message processing.

Macro that injects a horizontally-scalable RabbitMQ consumer pool.

Per-module dynamic supervisor for HareMq.DynamicConsumer worker pools.

Module providing functions for managing RabbitMQ exchanges.

Macro that injects a full RabbitMQ publisher GenServer into the calling module.

Functions for declaring and binding RabbitMQ queues.

Module providing functions for republishing messages with retry handling.

Telemetry events emitted by HareMq.

Internal GenServer that manages a single AMQP channel and processes messages.