kotovalexarian-likes-github/deanpcmad--sidekiq-limit_fetch
1
0
Fork 0
mirror of https://github.com/deanpcmad/sidekiq-limit_fetch.git synced 2022-11-09 13:54:36 -05:00
Code Releases Activity

Fix bug

Browse source
This commit is contained in:
brainopia 2013-01-11 16:01:46 +04:00
parent 2ba307a539
commit d6eb9bf28f
1 changed files with 2 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lib/sidekiq/limit_fetch.rb
View file

@ -1,4 +1,5 @@
require 'sidekiq'
require 'sidekiq/fetch'
class Sidekiq::LimitFetch
require_relative 'limit_fetch/semaphore'
@ -23,7 +24,7 @@ class Sidekiq::LimitFetch
end
if message
queue = queues.find {|it| it.name == queue_name }
queue = queues.find {|it| it.full_name == queue_name }
queues.delete queue
UnitOfWork.new queue, message