Sha256: bde4e0111b21f093d24d6c8ed336dbb16640311061b63dddcc969b74d87435d4
Contents?: true
Size: 1.29 KB
Versions: 17
Compression:
Stored size: 1.29 KB
Contents
require 'sucker_punch'
require 'sucker_punch/version'
module Rollbar
module Delay
class SuckerPunch
include ::SuckerPunch::Job
class << self
attr_accessor :perform_proc
attr_accessor :ready
end
self.ready = false
def self.setup
major_version = ::SuckerPunch::VERSION.split.first.to_i
if major_version > 1
self.perform_proc = proc { |payload| perform_async(payload) }
else
self.perform_proc = proc { |payload| new.async.perform(payload) }
end
self.ready = true
end
def self.call(payload)
setup unless ready
perform_proc.call(payload)
end
def perform(*args)
begin
Rollbar.process_from_async_handler(*args)
rescue
# SuckerPunch can configure an exception handler with:
#
# SuckerPunch.exception_handler { # do something here }
#
# This is just passed to Celluloid.exception_handler which will
# push the reiceved block to an array of handlers, by default empty, [].
#
# We reraise the exception here casue it's safe and users could have defined
# their own exception handler for SuckerPunch
raise
end
end
end
end
end
Version data entries
17 entries across 17 versions & 1 rubygems