class CrawlStation::ScheduleAdapters::MemoryAdapter
Public Class Methods
new()
click to toggle source
# File lib/crawl_station/schedule_adapters/memory_adapter.rb, line 4 def initialize @queue = Queue.new @queue.extend(MonitorMixin) %w(push pop empty?).each do |method_name| self.define_singleton_method method_name do |*args| @queue.synchronize do @queue.send(method_name, *args) end end end end
Public Instance Methods
failed(item)
click to toggle source
# File lib/crawl_station/schedule_adapters/memory_adapter.rb, line 16 def failed(item) CS.logger.debug "#{item.link} failed" end