rsmq_async 18.0.0

Async RSMQ port to rust. RSMQ is a simple redis queue system that works in any redis v2.4+. It contains the same methods as the original one in https://github.com/smrchy/rsmq
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

-- Atomically moves a single message from one queue to another, preserving its body
-- and the receive-count / first-received timestamps. The message becomes visible in
-- the destination queue immediately (score = current time).
--
-- KEYS[1]: ns:src     (source sorted set key)
-- KEYS[2]: ns:dst     (destination sorted set key)
-- ARGV[1]: message id
-- ARGV[2]: "1" for microsecond scores (break-js-comp), "0" for millisecond scores.
--
-- Returns 1 if the message was found and moved, 0 if it didn't exist in the source.

local src_hash = KEYS[1] .. ":Q"
local dst_hash = KEYS[2] .. ":Q"

local body = redis.call("HGET", src_hash, ARGV[1])
if not body then
    return 0
end

local rc = redis.call("HGET", src_hash, ARGV[1] .. ":rc")
local fr = redis.call("HGET", src_hash, ARGV[1] .. ":fr")

local time = redis.call("TIME")
local score
if ARGV[2] == "1" then
    score = tonumber(time[1]) * 1000000 + tonumber(time[2])
else
    score = tonumber(time[1]) * 1000 + math.floor(tonumber(time[2]) / 1000)
end

redis.call("ZADD", KEYS[2], score, ARGV[1])
redis.call("HSET", dst_hash, ARGV[1], body)
-- Always set :rc and :fr together (or neither) so receiveMessage.lua's HGET on :fr
-- never returns nil for a message with rc > 0. If the source had rc but no :fr (a
-- message moved before its first delivery), default :fr to the current score.
if rc then
    redis.call("HSET", dst_hash, ARGV[1] .. ":rc", rc)
    redis.call("HSET", dst_hash, ARGV[1] .. ":fr", fr or score)
end
redis.call("HINCRBY", dst_hash, "totalsent", 1)

redis.call("ZREM", KEYS[1], ARGV[1])
redis.call("HDEL", src_hash, ARGV[1], ARGV[1] .. ":rc", ARGV[1] .. ":fr")

return 1