Sha256: 701eef05edbe3aed16634140fb046714f20ec27ecf208300fe3924271292a98f
Contents?: true
Size: 700 Bytes
Versions: 22
Compression:
Stored size: 700 Bytes
Contents
if defined?(::Sidekiq)
Appsignal.logger.info('Loading Sidekiq integration')
module Appsignal
module Integrations
class SidekiqPlugin
def call(worker, item, queue)
Appsignal.monitor_transaction(
'perform_job.sidekiq',
:class => item['class'],
:method => 'perform',
:attempts => item['retry_count'],
:queue => item['queue'],
:queue_start => item['enqueued_at']
) do
yield
end
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
22 entries across 22 versions & 1 rubygems