Contents

require 'sidekiq'

module Rollbar
  module Delay
    class Sidekiq
      OPTIONS = { 'queue' => 'rollbar', 'class' => Rollbar::Delay::Sidekiq }.freeze

      def initialize(*args)
        @options = (opts = args.shift) ? OPTIONS.merge(opts) : OPTIONS
      end

      def call(payload)
        if ::Sidekiq::Client.push(@options.merge('args' => [payload])) == nil
          raise StandardError.new "Unable to push the job to Sidekiq"
        end
      end

      include ::Sidekiq::Worker

      def perform(*args)
        begin
          Rollbar.process_from_async_handler(*args)
        rescue
          # Raise the exception so Sidekiq can track the errored job
          # and retry it
          raise
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
rollbar-2.19.2	lib/rollbar/delay/sidekiq.rb
rollbar-2.19.1	lib/rollbar/delay/sidekiq.rb
rollbar-2.19.0	lib/rollbar/delay/sidekiq.rb