Simple, RESTful, Scalable Messaging

  #!/bin/bash

  HOST="https://api.okmq.net"
  TOKEN="${OKMQ_TOKEN}"

  # Create queue (only needed once)
  curl -s -X POST -H "Authorization: $TOKEN" -H "Content-Type: application/json" \
    -d '{"name":"demo","auto_ack":true}' "$HOST/queues" >/dev/null

  consumer() {
    while true; do
      body=$(curl -s -H "Authorization: $TOKEN" "$HOST/queues/demo/messages")
      echo "📨 Received: $body"
    done
  }

  producer() {
    while true; do
      timestamp=$(date -u +"%Y-%m-%dT%H:%M:%S.%3NZ")
      message_id="msg-$(date +%s%3N)"
      json_payload='[ { "id": "'"$message_id"'", "body": "Hello at '"$timestamp"'" } ]'
      curl -s -X POST -H "Authorization: $TOKEN" -H "Content-Type: application/json" \
        -d "$json_payload" "$HOST/queues/demo/messages" >/dev/null
      sleep 1
    done
  }

  # Trap SIGINT
  cleanup() {
    kill "$(jobs -p)" 2>/dev/null
    exit 0
  }
  trap cleanup SIGINT

  # Start consumer in background
  consumer &

  # Start producer
  producer