Contents

# encoding: utf-8

module Ratchetio
  class Sidekiq
    def call(worker, msg, queue)
      begin
        yield
      rescue => e
        msg.delete('backtrace')
        msg.delete('error_backtrace')
        msg.delete('error_message')
        msg.delete('error_class')

        Ratchetio.report_exception(e, :params => msg)
        raise
      end
    end
  end
end

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

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
ratchetio-0.7.1	lib/ratchetio/sidekiq.rb
ratchetio-0.7.0	lib/ratchetio/sidekiq.rb
ratchetio-0.6.3	lib/ratchetio/sidekiq.rb
ratchetio-0.6.1	lib/ratchetio/sidekiq.rb
ratchetio-0.6.0	lib/ratchetio/sidekiq.rb