lib/dispatch-rider/integrations/appsignal.rb in dispatch-rider-1.2.7 vs lib/dispatch-rider/integrations/appsignal.rb in dispatch-rider-1.2.8
- old
+ new
@@ -1,49 +1,48 @@
if defined? Appsignal
- Appsignal.logger.info('Loading Dispatch Rider integration')
+ ::Appsignal.logger.info('Loading Dispatch Rider integration')
module DispatchRider
module Integrations
module Appsignal
def self.wrap_message(job, message)
begin
- Appsignal::Transaction.create(SecureRandom.uuid, ENV.to_hash)
+ ::Appsignal::Transaction.create(SecureRandom.uuid, ENV.to_hash)
- ActiveSupport::Notifications.instrument(
+ ::ActiveSupport::Notifications.instrument(
'perform_job.dispatch-rider',
:class => message.subject,
:method => 'handle',
:attempts => message.receive_count,
:queue => message.queue_name,
:queue_time => (Time.now.to_f - message.sent_at.to_f) * 1000
) do
job.call
end
rescue Exception => exception
- unless Appsignal.is_ignored_exception?(exception)
- Appsignal::Transaction.current.add_exception(exception)
+ unless ::Appsignal.is_ignored_exception?(exception)
+ ::Appsignal::Transaction.current.add_exception(exception)
end
raise exception
ensure
- Appsignal::Transaction.current.complete!
+ ::Appsignal::Transaction.current.complete!
end
end
end
end
end
- if Appsignal.active?
- Appsignal.start
+ DispatchRider.configure do |config|
- DispatchRider.configure do |config|
-
- config.around(:dispatch_message) do |job, message|
- DispatchRider::Integrations::Appsignal.wrap_message(job, message)
- end
-
+ config.around(:dispatch_message) do |job, message|
+ DispatchRider::Integrations::Appsignal.wrap_message(job, message)
end
+ end
+
+ if ::Appsignal.active?
+ ::Appsignal.start
end
end