require 'rubygems'
gem 'tmm1-amqp'
require 'mq'
 
AMQP.start do
  exch = MQ.headers("foo", :auto_delete => true)
 
  #Setup publishers
  EM.add_periodic_timer(0.5) do 
    exch.publish("Message 1", :headers => {:foo => "bar", :baz => "paz"})
  end
  
  EM.add_periodic_timer(1) do
    exch.publish("Message 2", :headers => {:foo => "paz", :baz => "bar"})
  end
  
  EM.add_periodic_timer(0.75) do
    exch.publish("Message 3", :headers => {:foo => "bar", :baz => "false"})
  end
  
  EM.add_periodic_timer(4) do 
    exch.publish("POTENTIAL DUPLICATE #{Time.now}", :headers => {:foo => "paz", :baz => "false"});
  end
  
  queue1 = MQ.queue("the_queue", :auto_delete => true)
  queue2 = MQ.queue("another_queue", :auto_delete => true)
  
  queue1.bind(exch, :arguments => {:foo => "bar", :baz => "paz"})
  queue1.bind(exch, :arguments => {:foo => "paz"})
  queue1.bind(exch, :arguments => {:baz => "false"})
  
  queue2.bind(exch, :arguments => {:foo => "paz"})
  
  EM.add_timer(3) do
    puts "Unbinding Some Stuff"
    queue1.unbind(exch, :arguments => {:baz => "false"})
  end  
  
  queue1.subscribe do |header, msg|
    puts "Message QUEUE1: \n#{msg.inspect}\n\n"
  end
  
  queue2.subscribe do |header, msg|
    puts "Message QUEUE2: \n#{msg.inspect}"
  end
end