Add demo tasks for blocking and advanced blocking

demo/Rakefile

@@ -22,6 +22,45 @@ namespace :demo do
     YAML
   end
 
+  task blocking: :environment do
+    puts '=> Creating sidekiq tasks'
+
+    AWorker.perform_async
+    BWorker.perform_async
+    CWorker.perform_async
+
+    run_sidekiq_monitoring
+    run_sidekiq_workers config: <<-YAML
+      :verbose: false
+      :concurrency: 4
+      :queues:
+        - a
+        - b
+        - c
+      :blocking:
+        - a
+    YAML
+  end
+
+  task advanced_blocking: :environment do
+    puts '=> Creating sidekiq tasks'
+
+    AWorker.perform_async
+    BWorker.perform_async
+    CWorker.perform_async
+
+    run_sidekiq_monitoring
+    run_sidekiq_workers config: <<-YAML
+      :verbose: false
+      :concurrency: 4
+      :queues:
+        - a
+        - b
+        - c
+      :blocking:
+        - [a, b]
+    YAML
+  end
   def with_sidekiq_config(config)
     whitespace_offset = config[/\A */].size
     config.gsub! /^ {#{whitespace_offset}}/, ''
@@ -51,8 +90,7 @@ namespace :demo do
     end
 
     with_sidekiq_config options[:config] do
-      config = cli.send :parse_config, 'config/sidekiq.yml'
-      Sidekiq.options.merge! config
+      cli.send :setup_options, []
     end
 
     cli.run

demo/app/workers/a_worker.rb

@@ -0,0 +1,8 @@
+class AWorker
+  include Sidekiq::Worker
+  sidekiq_options queue: :a
+
+  def perform
+    sleep 10
+  end
+end

demo/app/workers/b_worker.rb

@@ -0,0 +1,8 @@
+class BWorker
+  include Sidekiq::Worker
+  sidekiq_options queue: :b
+
+  def perform
+    sleep 10
+  end
+end

demo/app/workers/c_worker.rb

@@ -0,0 +1,9 @@
+class CWorker
+  include Sidekiq::Worker
+  sidekiq_options queue: :c
+
+  def perform
+    sleep 10
+  end
+end
+