Add delay option into Shoryuken.add_group

lib/shoryuken/environment_loader.rb

@@ -130,7 +130,7 @@ def parse_queues
       end
 
       Shoryuken.options[:groups].to_a.each do |group, options|
-        Shoryuken.add_group(group, options.fetch(:concurrency, 25))
+        Shoryuken.add_group(group, options.fetch(:concurrency, 25), delay: options.fetch(:delay, 0))
         options[:queues].to_a.each do |queue, weight|
           parse_queue(queue, weight, group)
         end

lib/shoryuken/polling/base.rb

@@ -60,7 +60,11 @@ def ==(other)
       private
 
       def delay
-        Shoryuken.options[:delay].to_f
+        if name == 'default'
+          Shoryuken.options[:delay].to_f
+        else # allow delay settings per group
+          Shoryuken.options[:groups].to_h[name]).to_h[:delay]
+        end
       end
     end
   end

spec/shoryuken/environment_loader_spec.rb

@@ -4,7 +4,7 @@
 RSpec.describe Shoryuken::EnvironmentLoader do
   subject { described_class.new({}) }
 
-  describe '#parse_queues' do
+  describe '#parse_queues loads default queues' do
     before do
       allow(subject).to receive(:load_rails)
       allow(subject).to receive(:prefix_active_job_queue_names)
@@ -22,6 +22,29 @@
     end
   end
 
+  describe '#parse_queues includes delay per groups' do
+    before do
+      allow(subject).to receive(:load_rails)
+      allow(subject).to receive(:prefix_active_job_queue_names)
+      allow(subject).to receive(:require_workers)
+      allow(subject).to receive(:validate_queues)
+      allow(subject).to receive(:validate_workers)
+      allow(subject).to receive(:patch_deprecated_workers)
+    end
+
+    specify do
+      Shoryuken.options[:queues] = ['queue1', 'queue2'] # default queues
+      Shoryuken.options[:groups] = [[ 'custom', { queues: ['queue3'], delay: 25 }]]
+      subject.load
+
+      expect(Shoryuken.groups['default'][:queues]).to eq(%w[queue1 queue2])
+      expect(Shoryuken.groups['default'][:delay]).to eq(0)
+      expect(Shoryuken.groups['custom'][:queues]).to eq(%w[queue3])
+      expect(Shoryuken.groups['custom'][:delay]).to eq(25)
+    end
+  end
+
+
   describe '#prefix_active_job_queue_names' do
     before do
       allow(subject).to receive(:load_rails)