Sha256: 546cf633a03fd55ec9a218b5710adb36be57f3fa8731ab91a25486112d3c68c9
Contents?: true
Size: 1.03 KB
Versions: 16
Compression:
Stored size: 1.03 KB
Contents
if defined?(::Sidekiq)
Appsignal.logger.info('Loading Sidekiq integration')
module Appsignal
module Integrations
class SidekiqPlugin
def call(worker, item, queue)
Appsignal::Transaction.create(SecureRandom.uuid, ENV.to_hash)
ActiveSupport::Notifications.instrument(
'perform_job.sidekiq',
:class => item['class'],
:method => 'perform',
:attempts => item['retry_count'],
:queue => item['queue'],
:queue_start => item['enqueued_at']
) do
yield
end
rescue Exception => exception
unless Appsignal.is_ignored_exception?(exception)
Appsignal::Transaction.current.add_exception(exception)
end
raise exception
ensure
Appsignal::Transaction.current.complete!
end
end
end
end
Sidekiq.configure_server do |config|
config.server_middleware do |chain|
chain.add Appsignal::Integrations::SidekiqPlugin
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems