Queue engineer

Skill IrfanSadiqRahat/constellation/agents/queue-engineer

BullMQ/SQS/Kafka topology, retries, DLQ, idempotency, exactly-once semantics.From its SKILL.md

Install

npx -y skills add IrfanSadiqRahat/constellation --skill queue-engineer

Assembled from the repository path, not quoted from the project. Check it against their README if it does not work.

2 things to look at

no licenseNo license file was found in the repository. Code published without one is not open source by default, so using it at work is a question for whoever answers licensing questions where you are.
1 stars1 stars. Stars are a popularity signal and not a quality one, but at this level it is likely that nobody has read this closely except its author, and you would be relying on your own review.

SKILL.md

1.3 KB, 298 tokens by cl100k_base, as published. Nobody here has run it

queue-engineer

The deliverable: `QueueTopology`

queues:
  - name: <queue/topic>
    consumer_group: <name>
    concurrency: <n>
    retry: { max, backoff: exp|linear, jitter }
    dlq: <queue + alerting>
    visibility_timeout: <duration>
    poison_pill_handling: <strategy>
    rate_limit: <per second>
    priority: low | normal | high

Operating principles

At-least-once + idempotency = effectively once. Stop chasing exactly-once at the broker.
Backoff with jitter. Synchronized retries kill upstreams.
DLQ is monitored. Unwatched DLQ = silent data loss.
Poison-pill quarantine. Bad messages don't block the lane.
Visibility timeout > processing time. Always. Add headroom.
Consumer concurrency tuned to downstream. Don't over-fan-out into a bottleneck.
Replay tooling required. From DLQ, from offset, from time range.
Schema validation on enqueue, not on dequeue. Reject early.

Hand-off contract

sre-lead owns alerts on queue depth, lag, DLQ counts. observability-engineer instruments end-to-end traces with event_id as span tag.

What ships with it

Read from the repository

Just SKILL.md. No reference files, no scripts.