tweet-daemon.rb

DaemonKit::AMQP.run do
  # Inside this block we're running inside the reactor setup by the
  # amqp gem. Any code in the examples (from the gem) would work just
  # fine here.

  MQ.prefetch(10)

  # Uncomment this for connection keep-alive
  AMQP.conn.connection_status do |status|
    DaemonKit.logger.debug("AMQP connection status changed: #{status}")
    if status == :disconnected
      AMQP.conn.reconnect(true)
    end
  end

  amq = ::MQ.new
  amq.queue('search').subscribe(:ack => true) do |header, msg|
    #EM.defer {
    begin
      DaemonKit.logger.debug "[search] Searching for: #{msg.strip}"
      Twitter::Search.new( msg ).per_page(2).each do |r|
        DaemonKit.logger.debug "[search] #{msg.strip}: #{r.text[0,60]}"
      end
    rescue => e
      DaemonKit.logger.warn "[search] #{e.message}"
    end

    header.ack
    #}
  end

  amq = ::MQ.new
  amq.queue('tweeps').subscribe(:ack => true) do |header, msg|
    #EM.defer {
    begin
      DaemonKit.logger.debug "[tweep] Getting latest tweets for #{msg}"
      Twitter::Search.new.from( msg ).per_page(2).each do |r|
        DaemonKit.logger.debug "[tweep] #{msg}: #{r.text[0,60]}"
      end
    rescue => e
      DaemonKit.logger.warn "[tweep] #{e.message}"
    end

    header.ack
    #}
  end
end

tweet.rb

#
# ruby tweet.rb username password /path/to/dictionary

require 'rubygems'
require 'twitter'
require 'mq'
  
AMQP.start do
  
  amq = MQ.new
  
  auth = Twitter::HTTPAuth.new( ARGV[0], ARGV[1] )
  client = Twitter::Base.new( auth )
  client.followers.each do |f|
    amq.queue( 'tweeps' ).publish( f.screen_name )
  end
  
  dictionary = IO.readlines( ARGV[2] )
  50.times do
    amq.queue( 'search' ).publish( dictionary[ rand( dictionary.size ) ].strip )
  end
    
  AMQP.stop { EM.stop }
end