lib/sidekiq.rb in sidekiq-2.6.0 vs lib/sidekiq.rb in sidekiq-2.6.1

- old
+ new

@@ -2,11 +2,10 @@ require 'sidekiq/logging' require 'sidekiq/client' require 'sidekiq/worker' require 'sidekiq/redis_connection' require 'sidekiq/util' -require 'sidekiq/stats' require 'sidekiq/api' require 'sidekiq/extensions/class_methods' require 'sidekiq/extensions/action_mailer' require 'sidekiq/extensions/active_record' @@ -105,8 +104,20 @@ Sidekiq::Logging.logger = log end def self.poll_interval=(interval) self.options[:poll_interval] = interval + end + + ## + # deprecated + def self.size(*queues) + return Sidekiq::Stats.new.enqueued if queues.empty? + + Sidekiq.redis { |conn| + conn.multi { + queues.map { |q| conn.llen("queue:#{q}") } + } + }.inject(0) { |memo, count| memo += count } end end