amqp multi exchange subscribe

#!/usr/bin/ruby

require 'rubygems'
require 'mq'

EM.run {
  amq = MQ.new

  amq.topic('evp-started')
  amq.topic('evp-stopped')

  amq.queue('evc-capall').bind('evp-started', :key=>'*')
  amq.queue('evc-capall').bind('evp-stopped', :key=>'*')
  amq.queue('evc-capall').subscribe{ |msg|
    puts msg
  }

  EM.add_periodic_timer(3) {
    amq.topic('evp-started').publish('from started', :key=>'nnn')
  }

  EM.add_periodic_timer(4) {
    amq.topic('evp-stopped').publish('from stopped', :key=>'ttt')
  }

}