Merge pull request #1 from FlavourSys/feature/sidekiq4

Add support for sidekiq 4

Author: bigzed

lib/sidekiq-queue-pause.rb

@@ -1,4 +1,8 @@
-require 'celluloid'
+begin
+  require 'celluloid'
+rescue LoadError
+  # Sidekiq 4.2+
+end
 require 'sidekiq'
 require 'sidekiq/fetch'
 
@@ -48,7 +52,7 @@ def retrieve_work
         if qcmd.size > 1
           retrieve_work_for_queues qcmd
         else
-          sleep(Sidekiq::QueuePause.retry_after || Sidekiq::Fetcher::TIMEOUT)
+          sleep(Sidekiq::QueuePause.retry_after || Sidekiq::BasicFetch::TIMEOUT)
           nil
         end
       end
@@ -61,7 +65,7 @@ def retrieve_work_for_queues(qcmd)
       def unpaused_queues_cmd
         queues = queues_cmd
         queues.reject do |q|
-          q != Sidekiq::Fetcher::TIMEOUT &&
+          q != Sidekiq::BasicFetch::TIMEOUT &&
             Sidekiq::QueuePause.paused?(q.gsub('queue:', ''), Sidekiq::QueuePause.process_key)
         end
       end

sidekiq-queue-pause.gemspec

@@ -11,5 +11,5 @@ Gem::Specification.new do |s|
   s.require_paths = ['lib']
   s.files         = Dir['lib/**/*rb']
 
-  s.add_dependency 'sidekiq', '~> 3.1'
+  s.add_dependency 'sidekiq', '>= 4.0', '< 5.0'
 end