Sha256: da4cc8b2c4240bc32267c28cde175faa3bf2bdd1ae86b4658b4b528d9090482d
Contents?: true
Size: 656 Bytes
Versions: 50
Compression:
Stored size: 656 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)
begin
Rollbar.process_from_async_handler(payload)
rescue
# Raise the exception so Resque can track the errored job
raise
end
end
end
end
end
end
Version data entries
50 entries across 50 versions & 1 rubygems