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-1.8.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.7.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.6.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.5.3	examples/guides/getting_started/03_blabbr.rb
amqp-1.5.2	examples/guides/getting_started/03_blabbr.rb
amqp-1.5.1	examples/guides/getting_started/03_blabbr.rb
amqp-1.5.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.4.2	examples/guides/getting_started/03_blabbr.rb
amqp-1.4.1	examples/guides/getting_started/03_blabbr.rb
amqp-1.4.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.3.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.2.1	examples/guides/getting_started/03_blabbr.rb
amqp-1.2.0	examples/guides/getting_started/03_blabbr.rb
amqp-1.1.8	examples/guides/getting_started/03_blabbr.rb
amqp-1.1.7	examples/guides/getting_started/03_blabbr.rb
amqp-1.1.6	examples/guides/getting_started/03_blabbr.rb
amqp-1.1.5	examples/guides/getting_started/03_blabbr.rb
amqp-1.1.4	examples/guides/getting_started/03_blabbr.rb
amqp-1.1.3	examples/guides/getting_started/03_blabbr.rb
amqp-1.0.4	examples/guides/getting_started/03_blabbr.rb