Contents

require "sneakers"
require 'open-uri'
require 'logger'

def compose_or_localhost(key)
  Resolv::DNS.new.getaddress(key)
rescue 
  "localhost"
end

rmq_addr = compose_or_localhost("rabbitmq")

Sneakers.configure :log => STDOUT, :amqp => "amqp://guest:guest@#{rmq_addr}:5672"
Sneakers.logger.level = Logger::INFO

class TitleScraper
  include Sneakers::Worker

  from_queue 'downloads'

  def work(msg)
    title = extract_title(open(msg))
    logger.info "FOUND <#{title}>"
    ack!
  end

  private

  def extract_title(html)
    html =~ /<title>(.*?)<\/title>/
    $1
  end
end

Version data entries

12 entries across 12 versions & 2 rubygems

Version	Path
kicks-3.2.0	examples/title_scraper.rb
kicks-3.1.1	examples/title_scraper.rb
kicks-3.1.0	examples/title_scraper.rb
kicks-3.0.0	examples/title_scraper.rb
kicks-3.0.0.pre	examples/title_scraper.rb
sneakers-2.12.0	examples/title_scraper.rb
sneakers-2.12.0.rc1	examples/title_scraper.rb
sneakers-2.11.0	examples/title_scraper.rb
sneakers-2.7.0	examples/title_scraper.rb
sneakers-2.6.0	examples/title_scraper.rb
sneakers-2.5.0	examples/title_scraper.rb
sneakers-2.4.0	examples/title_scraper.rb