Contents

#!/usr/bin/env ruby
# encoding: utf-8

require "rubygems"
require "amqp"

AMQP.start("amqp://dev.rabbitmq.com:5672") do |connection|
  channel  = AMQP::Channel.new(connection)
  exchange = channel.fanout("nba.scores")

  channel.queue("joe", :auto_delete => true).bind(exchange).subscribe do |payload|
    puts "#{payload} => joe"
  end

  channel.queue("aaron", :auto_delete => true).bind(exchange).subscribe do |payload|
    puts "#{payload} => aaron"
  end

  channel.queue("bob", :auto_delete => true).bind(exchange).subscribe do |payload|
    puts "#{payload} => bob"
  end

  exchange.publish("BOS 101, NYK 89").publish("ORL 85, ALT 88")

  # disconnect & exit after 2 seconds
  EventMachine.add_timer(2) do
    exchange.delete

    connection.close {
      EM.stop { exit }
    }
  end
end

Version data entries

55 entries across 55 versions & 1 rubygems

Version	Path
amqp-0.9.2	examples/guides/getting_started/03_blabbr.rb
amqp-0.9.1	examples/guides/getting_started/03_blabbr.rb
amqp-0.9.0	examples/guides/getting_started/03_blabbr.rb
amqp-0.9.0.pre3	examples/guides/getting_started/03_blabbr.rb
amqp-0.9.0.pre2	examples/guides/getting_started/03_blabbr.rb
amqp-0.9.0.pre1	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.4	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.3	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.2	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.1	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.0	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.0.rc15	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.0.rc14	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.0.rc13	examples/guides/getting_started/03_blabbr.rb
amqp-0.8.0.rc12	examples/guides/getting_started/03_babblr.rb