Contents

require 'sidekiq'

module YogiBerra
  class Sidekiq
    def call(worker, message, queue)
      begin
        yield
      rescue Exception => exception
        message["worker"] = message.delete("jid")
        YogiBerra.exceptionize(exception, :sidekiq => message)
        raise exception
      end
    end
  end
end

::Sidekiq.configure_server do |config|
  config.server_middleware do |chain|
    chain.add ::YogiBerra::Sidekiq
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
yogi_berra-0.2.1	lib/yogi_berra/sidekiq.rb
yogi_berra-0.2.0	lib/yogi_berra/sidekiq.rb