Product demo only: This is a portfolio showcase build and is not intended for heavy production traffic.

Built by Aniket Ghavte · aniketghavte.xyz · GitHub

Distributed Job Queue Platform

A minimal, production-style async processing system using BullMQ and Redis. Monitor queue health, trigger jobs, and watch live worker events in one place.

Click here to see the architecture and storyHow it works · Why it matters · Why I built this
Client / Dashboard
       |
       | HTTP + WebSocket
       v
API (Express + BullMQ Producer)
       |
       v
Redis Queue (email / image / ai)
       |
       v
Workers (email, image, ai)
       |
       v
Prometheus --> Grafana

If I explain this like I am talking to you directly: this system is built so the app does not freeze when heavy work comes in. Instead of doing everything in one API request, I push jobs to queues and let background workers process them safely.

How it works: the API receives a task, validates it, and puts it in Redis via BullMQ. Dedicated workers pick jobs by queue type (email, image, AI), execute them with retries and backoff, and report status. The dashboard shows current queue health and live events.

How it benefits: fast user response times, better reliability when failures happen, safer retry behavior, and clear visibility through metrics. This is the same mindset used in real product teams when they handle async workloads.

What makes it different and unique: this is not just a basic queue demo. It combines multi-queue processing, real-time event streaming, observability with Prometheus/Grafana, and a polished monitoring UI in one system.

Why I made this: I wanted to showcase real backend engineering ownership end-to-end, not only API coding. This project demonstrates how I design systems that are scalable, observable, and ready for production-style traffic patterns.

What this demo shows

Decoupling heavy tasks from request-response flows so APIs stay responsive while workers process jobs in the background.

Queues and workers

Separate queues for email, image, and AI with retries, progress updates, and queue-specific concurrency controls.

Observability

Metrics are exported to Prometheus and visualized in Grafana for throughput, queue depth, latency, and retry behavior.

Quick submit actions

Use these actions to generate queue traffic and see real-time updates below.

Live event stream · WebSocket `/live`

Waiting for queue events…