message_handler.rb

class MessageHandler 

  NUM_TRIES = 3
  TIMEOUT = 5 #seconds

  def initialize
    @queue = EM::Queue.new
  end

  def add_get_request(destinations)
    destinations.each{ |dest| @queue.push(Message.new(:get, dest))}
  end


  def add_post_request(destinations, body)
    b = body
    destinations.each{|dest| @queue.push(Message.new(:post, dest, b))}
  end

  def process
    @queue.pop{ |query|
      case query.type
      when :post
        puts "sending: #{query.body} to #{query.destination}"
        http = EventMachine::HttpRequest.new(query.destination).post :timeout => TIMEOUT, :body =>{:xml =>  query.body}
        http.callback {puts "success from: to #{query.destination}";  process}
      when :get
        http = EventMachine::HttpRequest.new(query.destination).get :timeout => TIMEOUT
        http.callback {send_to_seed(query, http.response); process}
      else
        raise "message is not a type I know!"
      end

      http.errback {
        puts "fauilure from #{query.destination}, retrying"
        query.try_count +=1
        @queue.push query unless query.try_count >= NUM_TRIES 
        process
      }
    } unless @queue.size == 0
  end
  
  def send_to_seed(message, http_response)
    #DO SOMETHING!
  end

  def size
    @queue.size
  end

  class Message
    attr_accessor :type, :destination, :body, :try_count
    def initialize(type, dest, body= nil)
      @type = type
      @destination = dest
      @body = body
      @try_count = 0
    end
  end
end