diff --git a/modules/extension/src/main/resources/redis/batchpop.lua b/modules/extension/src/main/resources/redis/batchpop.lua index 9dbc3674..549bc54e 100644 --- a/modules/extension/src/main/resources/redis/batchpop.lua +++ b/modules/extension/src/main/resources/redis/batchpop.lua @@ -2,13 +2,12 @@ -- ARGS: [1]currentTime, [2]batchsize, [3]reliable local batchJobs={} for i=1,ARGV[2] do - local job=redis.call('rpop', KEYS[1]) - batchJobs[i]=job + batchJobs[i]=redis.call('rpop', KEYS[1]) end if (ARGV[3]=='true') then for i=1,ARGV[2] do - redis.call('zadd', KEYS[2], ARGV[1], batchJobs[i]) + redis.call('zadd', KEYS[2], ARGV[1], batchJobs[i]) end end