Add queue_name configuration

README.md

@@ -45,6 +45,9 @@ $ gem install nexaas-async-collector
     # The namespace where you want to store you data within Redis
     config.redis_namespace = 'nexaas_async'
 
+    # The name of the sidekiq queue to be used
+    config.queue_name = :high_fast
+
     # The method that returns the user object (or any other object you want. It must respond to id method)
     config.scope = :current_user
 

app/workers/nexaas/async/collector/async_resource_job.rb

@@ -4,7 +4,7 @@ module Collector
       class AsyncResourceJob
 
         include Sidekiq::Worker
-        sidekiq_options queue: :high_fast
+        sidekiq_options queue: Nexaas::Async::Collector.queue_name
 
         def perform(collector_id, user_id, klass_name, klass_method, args=[])
           content = call_for_method(klass_name, klass_method, args)

lib/nexaas/async/collector.rb

@@ -17,6 +17,10 @@ module Collector
       mattr_accessor :redis_namespace
       @@redis_namespace = 'nexaas_async'
 
+      # Name of the sidekiq queue to be used
+      mattr_accessor :queue_name
+      @@queue_name = :high_fast
+
       # Method will be called to get the user/account id
       # This ID is used to store and ensure only the user
       # will fetch the processed data.

spec/lib/nexaas/async/collector_spec.rb

@@ -13,6 +13,10 @@
     it { expect(described_class.redis_namespace).to eq('nexaas_async') }
   end
 
+  describe '.queue_name' do
+    it { expect(described_class.queue_name).to eq(:high_fast) }
+  end
+
   describe '.scope' do
     it { expect(described_class.scope).to eq('current_user') }
   end
@@ -26,10 +30,12 @@
       described_class.configure do |c|
         c.redis_url = 'anything'
         c.redis_namespace = 'specific_namespace'
+        c.queue_name = 'faster'
       end
 
       expect(described_class.redis_url).to eq('anything')
       expect(described_class.redis_namespace).to eq('specific_namespace')
+      expect(described_class.queue_name).to eq('faster')
     end
   end
 end

spec/workers/nexaas/async/collector/async_resource_job_spec.rb

@@ -1,4 +1,5 @@
-require "rails_helper"
+require 'rails_helper'
+require 'sidekiq/testing'
 
 class DummyModel
   def self.generate(first_arg, second_arg)
@@ -13,6 +14,10 @@ def self.update
 describe Nexaas::Async::Collector::AsyncResourceJob do
   subject { described_class.new }
 
+  it 'uses the correct queue name' do
+    expect { described_class.perform_async }.to change(Sidekiq::Queues['high_fast'], :size).by(1)
+  end
+
   describe "#perform" do
     context "when there are additional args" do
       it 'invokes Persist.save' do