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