lib/sidekiq_bus/adapter.rb in sidekiq-bus-0.5.7 vs lib/sidekiq_bus/adapter.rb in sidekiq-bus-0.5.9

@@ -2,9 +2,16 @@
   module Adapters
     class Sidekiq < QueueBus::Adapters::Base
       def enabled!
         # know we are using it
         require 'sidekiq'
+
+        #this sidekiq middleware adds in the 'retry' key to the job payload so we ensure sidekiq plays well with resque
+        ::Sidekiq.configure_server do |config|
+          config.client_middleware do |chain|
+            chain.prepend ::SidekiqBus::Middleware::Client::Retry
+          end
+        end
         ::QueueBus::Worker.include ::Sidekiq::Worker
       end
 
       def redis(&block)
         ::Sidekiq.redis(&block)