LeanMQ

Replace your internal webhooks with a reliable, performant, and scalable MQ with a fantastic DX.

🧑‍💻

Beautiful DX

Its almost like your typical webhook. Try it with minimal changes, migrate when ready. Open source. Minimal dependencies.

🚀

Efficient

Make every CPU cycle and network request count. Stop wasting resources sending & receiving webhooks.

🎁

Feature packed

Has everything you need to scale — dead letter queues, retries, persistence, TTL, and even atomic transactions!

🦸

Powered by Redis Streams

Built for scale, based on code that is used in production to power ~15M webhooks/month with the goal to handle 100M+ webhooks/month.

pip install leanmq

# from leanmq import LeanMQWebhook
webhook = LeanMQWebhook()

Sending a webhook is easy

# Looks very similar to a POST request
webhook.send("/order/status/", {"id": "123", "status": "shipped"})

So is receiving them

# Looks just like Flask, FastAPI, etc.
@webhook.get("/order/status/")
def process_order_status(data):
    print(f"Order: {data['id']}, status: {data['status']}")

# Process in a dedicated worker (or scale to 1000s)
webhook.run_service()

# Don't need dedicated workers? Schedule this in a CRON instead.
webhook.process_messages()

… and get all of these for free

Freedom from retry handling and rate limiting • Failed webhooks automatically go to a dead letter queue • Set a TTL to automatically expire old webhooks • Persisted data so no more dropped webhooks • Atomic transactions for when you need them