lib/crawl_station/adapters/proxy_adapters/memory_adapter.rb
module CrawlStation
module Adapters
module ProxyAdapters
class MemoryAdapter < AbstractAdapter
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
def closed(item)
CS.logger.warn "proxy error #{item.inspect}"
end
end
end
end
end