Sha256: ea1ec6965937c003fded9ade21a9efe242ccf91467af3a2d1fc6a223ac426837

Contents?: true

Size: 583 Bytes

Versions: 27

Compression:

Stored size: 583 Bytes

Contents

require 'resque'

module Rollbar
  module Delay
    class Resque
      def self.call(payload)
        new.call(payload)
      end

      def call(payload)
        ::Resque.enqueue(Job, payload)
      end

      class Job
        class << self
          attr_accessor :queue
        end

        self.queue = :default

        def self.perform(payload)
          new.perform(payload)
        end

        def perform(payload)
          Rollbar.process_from_async_handler(payload)

          # Do not rescue. Resque will call the error handler.
        end
      end
    end
  end
end

Version data entries

27 entries across 27 versions & 1 rubygems

Version Path
rollbar-3.6.0 lib/rollbar/delay/resque.rb
rollbar-3.5.2 lib/rollbar/delay/resque.rb
rollbar-3.5.1 lib/rollbar/delay/resque.rb
rollbar-3.5.0 lib/rollbar/delay/resque.rb
rollbar-3.4.2 lib/rollbar/delay/resque.rb
rollbar-3.4.1 lib/rollbar/delay/resque.rb
rollbar-3.4.0 lib/rollbar/delay/resque.rb
rollbar-3.3.3 lib/rollbar/delay/resque.rb
rollbar-3.3.2 lib/rollbar/delay/resque.rb
rollbar-3.3.1 lib/rollbar/delay/resque.rb
rollbar-3.3.0 lib/rollbar/delay/resque.rb
rollbar-3.2.0 lib/rollbar/delay/resque.rb
rollbar-3.1.2 lib/rollbar/delay/resque.rb
rollbar-3.1.1 lib/rollbar/delay/resque.rb
rollbar-3.1.0 lib/rollbar/delay/resque.rb
rollbar-3.0.1 lib/rollbar/delay/resque.rb
rollbar-3.0.0 lib/rollbar/delay/resque.rb
rollbar-2.27.1 lib/rollbar/delay/resque.rb
rollbar-2.27.0 lib/rollbar/delay/resque.rb
rollbar-2.26.1 lib/rollbar/delay/resque.rb