Skip to content

Commit

Permalink
reduce spacing between messages to 3 seconds
Browse files Browse the repository at this point in the history
  • Loading branch information
nicpottier committed Jun 20, 2018
1 parent dd70194 commit 3661d82
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions queue/queue.go
Original file line number Diff line number Diff line change
Expand Up @@ -151,8 +151,8 @@ var luaPop = redis.NewScript(2, `-- KEYS: [EpochMS QueueType]
if table.getn(valueList) > 0 then
local remaining = cjson.encode(valueList)
-- schedule it in the future 5 seconds on our main queue
redis.call("zadd", queue .. "/1", tonumber(KEYS[1]) + 5, remaining)
-- schedule it in the future 3 seconds on our main queue
redis.call("zadd", queue .. "/1", tonumber(KEYS[1]) + 3, remaining)
redis.call("zincrby", KEYS[2] .. ":future", 0, queue)
end
Expand Down

0 comments on commit 3661d82

Please sign in to comment.