From d6eb9bf28fb651a7f7ef7df1de1ab0c5f3463cb8 Mon Sep 17 00:00:00 2001 From: brainopia Date: Fri, 11 Jan 2013 16:01:46 +0400 Subject: [PATCH] Fix bug --- lib/sidekiq/limit_fetch.rb | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/lib/sidekiq/limit_fetch.rb b/lib/sidekiq/limit_fetch.rb index 6a2edf2..b24972f 100644 --- a/lib/sidekiq/limit_fetch.rb +++ b/lib/sidekiq/limit_fetch.rb @@ -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