A small Redis Streams queue with at-least-once delivery and stale-message recovery.