diff --git a/Gemfile b/Gemfile index 89ed7076..4ee3daa8 100644 --- a/Gemfile +++ b/Gemfile @@ -2,6 +2,7 @@ source 'https://rubygems.org' gem 'sinatra' gem 'redis' +gem 'redis-namespace' gem 'sequel', '4.8.0' gem 'bcrypt' gem 'sinatra-flash', require: 'sinatra/flash' diff --git a/Gemfile.lock b/Gemfile.lock index bd3d27de..a07b695a 100644 --- a/Gemfile.lock +++ b/Gemfile.lock @@ -136,6 +136,8 @@ GEM rack (>= 1.0.0) rake (10.5.0) redis (3.2.2) + redis-namespace (1.5.2) + redis (~> 3.0, >= 3.0.4) rest-client (1.8.0) http-cookie (>= 1.0.2, < 2.0) mime-types (>= 1.16, < 3.0) @@ -262,6 +264,7 @@ DEPENDENCIES rack_session_access rake redis + redis-namespace rest-client rmagick ruby-debug diff --git a/workers/archive_worker.rb b/workers/archive_worker.rb index 4166c1af..4d29e515 100644 --- a/workers/archive_worker.rb +++ b/workers/archive_worker.rb @@ -1,4 +1,5 @@ require 'sidekiq/api' +require 'redis-namespace' class ArchiveWorker include Sidekiq::Worker @@ -13,7 +14,7 @@ class ArchiveWorker return end - queue = Sidekiq::Queues[self.class.sidekiq_options_hash['queue']] + queue = Sidekiq::Queue.new self.class.sidekiq_options_hash['queue'] logger.info "JOB ID: #{jid} #{site_id.inspect}" queue.each do |job| if job.args == [site_id] && job.jid != jid