gistfile1.txt

require 'mq'

AMQP.start :host=>"connectedhealth.in",:vhost=>"/test" do
  def log(*args)
    p [ Time.now, *args ]
  end

  mq = MQ.new
  mq.queue("testphr").bind(MQ.direct("eprescription",:key=>"apollopharmacy")).subscribe { |msg|
    log :received, msg
  }
end