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