Contents

module Sidekiq
  module Worker
    module ClassMethods
      def queue_size
        Sidekiq.redis do |conn|
          conn.llen("queue:#{get_sidekiq_options["queue"]}")
        end
      end
      def queue_items(start=0, finish=-1)
        Sidekiq.redis do |conn|
          conn.lrange("queue:#{get_sidekiq_options["queue"]}", start, finish)
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
cobweb-1.0.17	lib/sidekiq/cobweb_helper.rb
cobweb-1.0.16	lib/sidekiq/cobweb_helper.rb
cobweb-1.0.15	lib/sidekiq/cobweb_helper.rb
cobweb-1.0.12	lib/sidekiq/cobweb_helper.rb