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

Play even nicer with celluloid

Browse source
This commit is contained in:
Mike Perham 2012-04-18 17:06:46 -07:00
parent e980ed7c3c
commit be90cb2da4
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
lib/sidekiq/fetch.rb
View file

@ -10,9 +10,7 @@ module Sidekiq
include Celluloid
include Sidekiq::Util
# Timeout for Redis#blpop.
TIMEOUT = 1
RETRY_DELAY = 1
def initialize(mgr, queues)
@mgr = mgr
@ -43,7 +41,8 @@ module Sidekiq
rescue => ex
logger.error("Error while fetching messages: #{ex}")
logger.error(ex.backtrace.join("\n"))
after(RETRY_DELAY) { fetch }
sleep(TIMEOUT)
after(0) { fetch }
end
end
end