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

Version Path
shoryuken-3.1.2 lib/shoryuken/util.rb
shoryuken-3.1.1 lib/shoryuken/util.rb
shoryuken-3.1.0 lib/shoryuken/util.rb
shoryuken-3.0.11 lib/shoryuken/util.rb
shoryuken-3.0.10 lib/shoryuken/util.rb
shoryuken-3.0.9 lib/shoryuken/util.rb
shoryuken-3.0.8 lib/shoryuken/util.rb
shoryuken-3.0.7 lib/shoryuken/util.rb
shoryuken-3.0.6 lib/shoryuken/util.rb
shoryuken-3.0.5 lib/shoryuken/util.rb
shoryuken-3.0.4 lib/shoryuken/util.rb
shoryuken-3.0.3 lib/shoryuken/util.rb
shoryuken-3.0.2 lib/shoryuken/util.rb
shoryuken-3.0.1 lib/shoryuken/util.rb
shoryuken-3.0.0 lib/shoryuken/util.rb