simple_mq - Message Queue for Eiffel

Overview

simple_mq provides message queue functionality for Eiffel applications including Redis Streams integration, publish/subscribe patterns, and asynchronous message handling.

Part of the Simple Eiffel ecosystem.

Quick Start

local
    mq: SIMPLE_MQ
    msg: SIMPLE_MQ_MESSAGE
do
    create mq.make
    create msg.make ("user.created", "{%"id%": 123}")
    mq.publish (msg)
end

Features

Message Queues

In-memory and Redis-backed queue implementations

Pub/Sub

Topic-based publish/subscribe messaging patterns

Structured Messages

Messages with metadata, timestamps, and correlation IDs

SCOOP Compatible

Thread-safe concurrent message handling

Installation

# Set environment variable
export SIMPLE_EIFFEL=/d/prod

# Add to ECF
<library name="simple_mq" location="$SIMPLE_EIFFEL/simple_mq/simple_mq.ecf"/>