Sha256: 5ee6c1e2ab57dc2a94a404c3a63889dfa36315c5b205452f8d3503e89a34e05c
Contents?: true
Size: 730 Bytes
Versions: 7
Compression:
Stored size: 730 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
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
7 entries across 7 versions & 1 rubygems