Merge pull request #55 from mattruzicka/master

Set process_limits before limits

lib/sidekiq/limit_fetch/queues.rb

@@ -9,8 +9,8 @@ class Sidekiq::LimitFetch
 
       options[:strict] ? strict_order! : weighted_order!
 
-      set :limit, options[:limits]
       set :process_limit, options[:process_limits]
+      set :limit, options[:limits]
       set_blocks options[:blocking]
     end
 

spec/sidekiq/limit_fetch/queues_spec.rb

@@ -3,16 +3,18 @@ require 'spec_helper'
 RSpec.describe Sidekiq::LimitFetch::Queues do
   subject { described_class.new options }
 
-  let(:queues)   { %w[queue1 queue2] }
-  let(:limits)   {{ 'queue1' => 3 }}
-  let(:strict)   { true }
-  let(:blocking) {}
+  let(:queues)         { %w[queue1 queue2] }
+  let(:limits)         {{ 'queue1' => 3 }}
+  let(:strict)         { true }
+  let(:blocking)       {}
+  let(:process_limits) {{ 'queue2' => 3 }}
 
   let(:options) do
     { queues:   queues,
       limits:   limits,
       strict:   strict,
       blocking: blocking,
+      process_limits: process_limits,
       namespace: Sidekiq::LimitFetch::Redis.determine_namespace }
   end
 
@@ -82,6 +84,11 @@ RSpec.describe Sidekiq::LimitFetch::Queues do
     expect(Sidekiq::Queue['queue2'].limit).not_to be
   end
 
+  it 'should set process_limits' do
+    subject
+    expect(Sidekiq::Queue['queue2'].process_limit).to eq 3
+  end
+
   context 'without strict flag' do
     let(:strict) { false }