module Shoryuken::Util
Public Instance Methods
elapsed(started_at)
click to toggle source
# File lib/shoryuken/util.rb, line 21 def elapsed(started_at) # elapsed in ms (Time.now - started_at) * 1000 end
fire_event(event, reverse = false, event_options = {})
click to toggle source
# File lib/shoryuken/util.rb, line 7 def fire_event(event, reverse = false, event_options = {}) logger.debug { "Firing '#{event}' lifecycle event" } arr = Shoryuken.options[:lifecycle_events][event] arr.reverse! if reverse arr.each do |block| begin block.call(event_options) rescue => ex logger.warn(event: event) logger.warn "#{ex.class.name}: #{ex.message}" end end end
logger()
click to toggle source
# File lib/shoryuken/util.rb, line 3 def logger Shoryuken.logger end
unparse_queues(queues)
click to toggle source
# File lib/shoryuken/util.rb, line 26 def unparse_queues(queues) queues.each_with_object({}) do |name, queue_and_weights| queue_and_weights[name] = queue_and_weights[name].to_i + 1 end.to_a end
worker_name(worker_class, sqs_msg, body = nil)
click to toggle source
# File lib/shoryuken/util.rb, line 32 def worker_name(worker_class, sqs_msg, body = nil) if Shoryuken.active_job? \ && !sqs_msg.is_a?(Array) \ && sqs_msg.message_attributes \ && sqs_msg.message_attributes['shoryuken_class'] \ && sqs_msg.message_attributes['shoryuken_class'][:string_value] \ == ActiveJob::QueueAdapters::ShoryukenAdapter::JobWrapper.to_s \ && body "ActiveJob/#{body['job_class']}" else worker_class.to_s end end