Ruby on Rails + AJAX + Mongrel + JMS/MQ/MOM = 即时通讯

 = query['timeout'].nil? ? TIMEOUT : (query['timeout'].to_i / 1000)         

      Timeout::timeout(timeout + 0.1) {   

        msg = receive_messages(conn)   

      }   

      logger.debug "output: #{msg}"   

         

      write_response(response,  msg)         

    rescue Timeout::Error         

      logger.debug "timeout occurred"   

      write_response(response, "<message type='TIMEOUT'/>")   

    rescue   

      logger.error "an error occurred: #{$!}"         

      write_response(response, "<message type='ERROR' value='#{Mongrel::HttpRequest.escape($!)}'/>")   

    end   

  end   

     

  private      

  # Return all pending message   

  def receive_messages(conn)   

    msg = conn.receive       

    output = msg.body       

    begin   

      Timeout::timeout(0.01) {   

        while !msg.nil?   

          output += msg.body   

          msg = conn.receive