Ticket #30: rabbitc.rb

require 'eventmachine'

class StompClient < EM::Connection
  include EM::Protocols::Stomp

  def connection_completed
    connect :login => 'guest', :passcode => 'guest'
  end

  def receive_msg msg
    if msg.command == "CONNECTED"
      subscribe '/some/topic'
    else
      p ['got a message', msg]
      puts msg.body
    end
  end

  def receive_data data
    log data.split("\n").map{|l| ">> #{l}"}
    super
  end
  
  def send_data data
    log data.split("\n").map{|l| "<< #{l}"}
    super
  end

  private
  
  def log msg
    puts msg
  end
end

EM.kqueue
EM.run{
  EM.connect 'localhost', 61613, StompClient
}