class CrawlProcessWorker

Sidekiq server is multi-threaded so our Redis connection pool size defaults to concurrency (-c)

Sidekiq.configure_server do |config|

config.redis = { :namespace => 'x', :url => 'redis://localhost:6379/14' }

end

Public Class Methods

queue_size() click to toggle source
# File lib/crawl_process_worker.rb, line 24
def self.queue_size
  Sidekiq.redis do |conn|
    conn.llen("queue:#{get_sidekiq_options["queue"]}")
  end
end

Public Instance Methods

perform(content) click to toggle source
# File lib/crawl_process_worker.rb, line 20
def perform(content)
  content = HashUtil.deep_symbolize_keys(content)
  puts "Dummy Processing for #{content[:url]}"
end