Use require_relative where possible
This commit is contained in:
parent
1f07ea1768
commit
cd967b136c
|
@ -1 +1 @@
|
||||||
require 'sidekiq/limit_fetch'
|
require_relative 'sidekiq/limit_fetch'
|
||||||
|
|
|
@ -23,7 +23,10 @@ class Sidekiq::LimitFetch
|
||||||
end
|
end
|
||||||
|
|
||||||
def retrieve_work
|
def retrieve_work
|
||||||
queue, message = fetch_message
|
queue, message = nil
|
||||||
|
puts Benchmark.measure {|x|
|
||||||
|
queue, message = fetch_message
|
||||||
|
}
|
||||||
UnitOfWork.new queue, message if message
|
UnitOfWork.new queue, message if message
|
||||||
end
|
end
|
||||||
|
|
||||||
|
@ -37,6 +40,7 @@ class Sidekiq::LimitFetch
|
||||||
|
|
||||||
def redis_blpop(*args)
|
def redis_blpop(*args)
|
||||||
return if args.size < 2
|
return if args.size < 2
|
||||||
|
puts "queues: #{args.inspect}"
|
||||||
Sidekiq.redis {|it| it.blpop *args }
|
Sidekiq.redis {|it| it.blpop *args }
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
Loading…
Reference in New Issue