Enable sidekiq options through configuration

.travis.yml

@@ -1,6 +1,9 @@
 language: ruby
+before_install:
+  - gem update --system
+  - gem install bundler
 before_script:
-  - bundle exec sidekiq -r ./spec/dummy_app/app.rb -L /tmp/sidekiq.log &
+  - bundle exec sidekiq -r ./spec/dummy_app/app.rb -L /tmp/sidekiq.log -q default -q my_queue &
   - sleep 1
 script: rspec spec
 bundler_args: --without=extras

README.md

@@ -32,6 +32,14 @@ class MyListener
 end
 ```
 
+## Configuration
+
+```ruby
+Wisper::Sidekiq.configure do |config|
+  config.sidekiq_options = { retry: 5, queue: :my_queue, backtrace: true }
+end
+```
+
 When publshing events the arguments must be simple as they need to be
 serialized. For example instead of sending an `ActiveRecord` model as an argument
 use its id instead.

lib/wisper/sidekiq.rb

@@ -4,17 +4,44 @@
 require 'wisper/sidekiq/version'
 
 module Wisper
+  module Sidekiq
+
+    def self.configure
+      yield(configuration)
+    end
+
+    def self.configuration
+      @configuration ||= Configuration.new
+    end
+  end
+
+  class Configuration
+    attr_accessor :sidekiq_options
+
+    def initialize
+      @sidekiq_options = {}
+    end
+  end
+
   class SidekiqBroadcaster
+
     def broadcast(subscriber, publisher, event, args)
-      subscriber.delay.public_send(event, *args)
+      subscriber.delay(sidekiq_options).public_send(event, *args)
     end
 
+
     def self.register
       Wisper.configure do |config|
         config.broadcaster :sidekiq, SidekiqBroadcaster.new
         config.broadcaster :async,   SidekiqBroadcaster.new
       end
     end
+
+    private
+
+    def sidekiq_options
+      Sidekiq.configuration.sidekiq_options
+    end
   end
 end
 

scripts/sidekiq

@@ -2,4 +2,4 @@
 
 set -e
 
-bundle exec rerun --dir spec/dummy_app/ -- bundle exec sidekiq -r ./spec/dummy_app/app.rb -L ./spec/dummy_app/logs/sidekiq.log
+bundle exec rerun --dir spec/dummy_app/ -- bundle exec sidekiq -r ./spec/dummy_app/app.rb -L ./spec/dummy_app/logs/sidekiq.log -q default -q my_queue

spec/wisper/sidekiq_broadcaster_spec.rb

@@ -0,0 +1,20 @@
+require 'wisper/sidekiq'
+
+RSpec.describe Wisper::SidekiqBroadcaster do
+  let(:broadcaster) { Wisper::SidekiqBroadcaster.new }
+  let(:subscriber) { spy('subscriber') }
+  let(:sidekiq_options) { { retry: 5, queue: :my_queue, backtrace: true } }
+
+  describe "#broadcast" do
+    before do
+      Wisper::Sidekiq.configure do |config|
+        config.sidekiq_options = sidekiq_options
+      end
+    end
+
+    it 'configures sidekiq with options' do
+      broadcaster.broadcast(subscriber, nil, :event, :args)
+      expect(subscriber).to have_received(:delay).with(sidekiq_options)
+    end
+  end
+end

spec/wisper/sidekiq_spec.rb

@@ -0,0 +1,22 @@
+require 'wisper/sidekiq'
+
+RSpec.describe Wisper::Sidekiq do
+  let(:sidekiq_options) { { retry: 5, queue: :my_queue, backtrace: true } }
+
+  describe "#configure" do
+    it "should write allowed configuration" do
+      Wisper::Sidekiq.configure do |config|
+        config.sidekiq_options = sidekiq_options
+      end
+      expect(Wisper::Sidekiq.configuration.sidekiq_options).to eq sidekiq_options
+    end
+
+    it "should raise exception for non-allowed configuration" do
+      expect {
+        Wisper::Sidekiq.configure do |config|
+          config.not_allowed = 'not allowed'
+        end
+      }.to raise_error(NoMethodError)
+    end
+  end
+end