MQTT
REST
Jobs are submitted via REST and stored as rows in PostgreSQL. pgmqtt outbound CDC dispatches each new row to workers over MQTT — no Redis, no RabbitMQ, no application server. Workers report results back via MQTT, and inbound mappings update the job rows. Your queue is your database.

Pipeline PostgREST → queue_stats

—
Queued
—
Running
—
Completed
—
Failed
—
Throughput / min
—
Avg Latency
—
Success Rate
—
Total Jobs

Workers PostgREST → workers

Waiting for workers...

Submit Job POST → jobs → CDC

Queue Metrics Rolling stats from queue_stats

Throughput (jobs/min)
Avg Latency (s)

Job History PostgREST → jobs

ID Type Status Worker Duration
Waiting for jobs...

MQTT Stream WebSocket → jobs/#

Waiting for connection...