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