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