Contents

require 'sidekiq'

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

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

      def call(payload)
        ::Sidekiq::Client.push @options.merge('args' => [payload])
      end

      include ::Sidekiq::Worker

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

Version data entries

19 entries across 19 versions & 1 rubygems

Version	Path
rollbar-0.12.19	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.18	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.17	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.16	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.15	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.14	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.13	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.12	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.11	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.10	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.9	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.8	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.7	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.6	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.5	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.3	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.2	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.1	lib/rollbar/delay/sidekiq.rb
rollbar-0.12.0	lib/rollbar/delay/sidekiq.rb