Contents

module Sidekiq
  module Middleware
    module Server
      class FailureJobs
        def call(*args)
          yield
        rescue => e
          data = {
            :failed_at => Time.now.strftime("%Y/%m/%d %H:%M:%S %Z"),
            :payload => args[1],
            :exception => e.class.to_s,
            :error => e.to_s,
            :backtrace => e.backtrace,
            :worker => args[1]['class'],
            :queue => args[2]
          }

          Sidekiq.redis.rpush(:failed, MultiJson.encode(data))
          raise
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
sidekiq-0.8.0	lib/sidekiq/middleware/server/failure_jobs.rb
sidekiq-0.7.0	lib/sidekiq/middleware/server/failure_jobs.rb