Contents

if Gem::Specification.find_all_by_name("sidekiq", ">=3.0.0").count > 1
  SIDEKIQ_INSTALLED = true
  require 'sidekiq'
else
  SIDEKIQ_INSTALLED = false
  puts "can't find sidekiq gem"
end

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

1 entries across 1 versions & 1 rubygems

Version	Path
cobweb-1.0.18	lib/sidekiq/cobweb_helper.rb