Contents

module Shoryuken
  module Util
    def watchdog(last_words)
      yield
    rescue => ex
      logger.error { last_words }
      logger.error { ex }
      logger.error { ex.backtrace.join("\n") }
    end

    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

4 entries across 4 versions & 1 rubygems

Version	Path
shoryuken-2.1.3	lib/shoryuken/util.rb
shoryuken-2.1.2	lib/shoryuken/util.rb
shoryuken-2.1.1	lib/shoryuken/util.rb
shoryuken-2.1.0	lib/shoryuken/util.rb