kotovalexarian-likes-github/mperham--sidekiq
1
0
Fork 0
mirror of https://github.com/mperham/sidekiq.git synced 2022-11-09 13:52:34 -05:00
Code Releases Activity

Use lpush, not rpush, when scheduling/retrying work

Browse source
This commit is contained in:
Mike Perham 2013-04-17 09:45:09 -07:00
parent af1553e08f
commit 2b8e3bd9ed
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/sidekiq/api.rb
View file

@ -223,7 +223,7 @@ module Sidekiq
results.map do |message|
msg = Sidekiq.load_json(message)
msg['retry_count'] = msg['retry_count'] - 1
conn.rpush("queue:#{msg['queue']}", Sidekiq.dump_json(msg))
conn.lpush("queue:#{msg['queue']}", Sidekiq.dump_json(msg))
end
end
end

2
lib/sidekiq/scheduled.rb
View file

@ -40,7 +40,7 @@ module Sidekiq
if conn.zrem(sorted_set, message)
conn.multi do
conn.sadd('queues', msg['queue'])
conn.rpush("queue:#{msg['queue']}", message)
conn.lpush("queue:#{msg['queue']}", message)
end
logger.debug("enqueued #{sorted_set}: #{message}") if logger.debug?
end