Sha256: 22a696fa9fcc51e70ef34e5770a330eacdff2c407e6cee718ef8c48f5a3e8991

Contents?: true

Size: 870 Bytes

Versions: 64

Compression:

Stored size: 870 Bytes

Contents

if defined?(Resque::Worker)
  Resque.send(:extend, Resque::Additions)
  Resque::Worker.send(:include, Resque::DynamicQueues)
  Resque::Worker.send(:include, Resque::SilenceDone) if ZuoraConnect.configuration.silencer_resque_finish == true
  Resque::Job.send(:include, Resque::SelfLookup)
end

if ENV['PROCESS_TYPE'] == 'worker'
  Rails.logger = ZuoraObservability::Logger.custom_logger(name: 'RailsWorker', level: Logger::INFO)
end

Resque.module_eval do
  # Returns a hash, mapping queue names to queue sizes
  def queue_sizes
    paused_queues = Resque.redis.zrange("PauseQueue", 0, -1).map! {|key| key.split("__")[0]}
    queue_names = queues.delete_if{|name| paused_queues.include?(name.split("_")[0])}

    sizes = redis.pipelined do
      queue_names.each do |name|
        redis.llen("queue:#{name}")
      end
    end

    Hash[queue_names.zip(sizes)]
  end
end

Version data entries

64 entries across 64 versions & 1 rubygems

Version Path
zuora_connect-3.2.11 config/initializers/resque.rb
zuora_connect-3.2.10 config/initializers/resque.rb
zuora_connect-3.2.9 config/initializers/resque.rb
zuora_connect-3.2.8 config/initializers/resque.rb
zuora_connect-3.2.7 config/initializers/resque.rb
zuora_connect-3.2.6 config/initializers/resque.rb
zuora_connect-3.2.5 config/initializers/resque.rb
zuora_connect-3.2.4 config/initializers/resque.rb
zuora_connect-3.2.3 config/initializers/resque.rb
zuora_connect-3.2.2 config/initializers/resque.rb
zuora_connect-3.2.0 config/initializers/resque.rb
zuora_connect-3.1.5.pre.g config/initializers/resque.rb
zuora_connect-3.1.5.pre.f config/initializers/resque.rb
zuora_connect-3.1.5.pre.e config/initializers/resque.rb
zuora_connect-3.1.5.pre.d config/initializers/resque.rb
zuora_connect-3.1.5.pre.c config/initializers/resque.rb
zuora_connect-3.1.5.pre.b config/initializers/resque.rb
zuora_connect-3.1.5.pre.a config/initializers/resque.rb
zuora_connect-3.1.5 config/initializers/resque.rb
zuora_connect-3.1.4 config/initializers/resque.rb