diff --git a/src/main/resources/workerScripts/jesque_pop.lua b/src/main/resources/workerScripts/jesque_pop.lua index fdaddeb1..7d9dca3d 100644 --- a/src/main/resources/workerScripts/jesque_pop.lua +++ b/src/main/resources/workerScripts/jesque_pop.lua @@ -11,7 +11,7 @@ end local ok, queueType = next(redis.call('TYPE', queueKey)) if queueType == 'zset' then - local i, lPayload = next(redis.call('ZRANGEBYSCORE', queueKey, '-inf', now, 'WITHSCORES')) + local i, lPayload = next(redis.call('ZRANGEBYSCORE', queueKey, '-inf', now, 'WITHSCORES', 'LIMIT' , '0' , '1')) if lPayload then payload = lPayload local frequency = redis.call('HGET', freqKey, payload)