Contents

require 'sidekiq'

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

      def self.handle(payload)
        item = @use_sidekiq.is_a?(Hash) ? OPTIONS.merge(@use_sidekiq) : OPTIONS

        ::Sidekiq::Client.push item.merge('args' => [payload])
      end

      include ::Sidekiq::Worker

      def perform(*args)
        Rollbar.process_payload(*args)
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
rollbar-0.10.10	lib/rollbar/delay/sidekiq.rb
rollbar-0.10.9	lib/rollbar/delay/sidekiq.rb
rollbar-0.10.8	lib/rollbar/delay/sidekiq.rb
rollbar-0.10.7	lib/rollbar/delay/sidekiq.rb
rollbar-0.10.6	lib/rollbar/delay/sidekiq.rb
rollbar-0.10.5	lib/rollbar/delay/sidekiq.rb