chainmq 1.3.2

A Redis-backed, type-safe job queue for Rust. Provides job registration and execution, delayed jobs, retries with backoff, and scalable workers.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

-- lua/claim_job.lua
-- Atomically claim a job from waiting queues (priority + FIFO/LIFO buckets, then legacy wait) and move to active.
-- KEYS[1..n-1] = wait lists in claim order (RPOP from each), KEYS[n] = active_key
-- ARGV[1] = pause_key (full Redis key). If key exists (SET by pause_queue), return nil without claiming.

local pause_key = ARGV[1]
if pause_key and pause_key ~= '' and redis.call('exists', pause_key) == 1 then
    return nil
end

local n = #KEYS
local active_key = KEYS[n]

for i = 1, n - 1 do
    local job_id = redis.call('rpop', KEYS[i])
    if job_id then
        redis.call('sadd', active_key, job_id)
        return job_id
    end
end

return nil