package/delayqueue
1
0
Fork 0
mirror of https://github.com/HDT3213/delayqueue.git synced 2025-10-05 07:06:53 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix:异步模式下消费者无法消费的bug

Browse Source
This commit is contained in:
iTuring
2024-03-22 16:06:49 +08:00
committed by finley
parent b1749b22b5
commit 2880c3239b
2 changed files with 30 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
delayqueue.go
View File

@@ -255,7 +255,7 @@ for _,v in ipairs(msgs) do
args2 = {}
end
end
if (#args2 > 2) then
if (#args2 > 0) then
redis.call('LPush', KEYS[2], unpack(args2))
end
redis.call('ZRemRangeByScore', KEYS[1], '0', ARGV[1]) -- remove msgs from pending