Sha256: 4ec39f6462819428610cad0df441ea904534af93faf006a647a242142aeee959
Contents?: true
Size: 1.23 KB
Versions: 15
Compression:
Stored size: 1.23 KB
Contents
module Shoryuken
module Util
def logger
Shoryuken.logger
end
def fire_event(event, reverse = false)
logger.debug { "Firing '#{event}' lifecycle event" }
arr = Shoryuken.options[:lifecycle_events][event]
arr.reverse! if reverse
arr.each do |block|
begin
block.call
rescue => ex
logger.warn(event: event)
logger.warn "#{ex.class.name}: #{ex.message}"
end
end
end
def elapsed(started_at)
# elapsed in ms
(Time.now - started_at) * 1000
end
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
def worker_name(worker_class, sqs_msg, body = nil)
if defined?(::ActiveJob) \
&& !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
end
end
Version data entries
15 entries across 15 versions & 1 rubygems