Rabbit Fanout Exchange Example

broadcaster.rb

require 'bunny'
require 'irb'

STDOUT.sync = true

conn = Bunny.new("amqp://guest:guest@localhost:5672")
conn.start

ch = conn.create_channel
$x = ch.fanout('msgs')

IRB.start(__FILE__)

# $x.publish('1').publis('2')

q1_suscriber.rb

require 'bunny'

STDOUT.sync = true

conn = Bunny.new("amqp://guest:guest@localhost:5672")
conn.start

ch = conn.create_channel
x  = ch.fanout('msgs')

ch.queue('q1').bind(x).subscribe(block: true) do |info, meta, payload|
  puts "payload: Q1 > #{payload}"
end

puts "Done"

q2_subscriber.rb

require 'bunny'

STDOUT.sync = true

conn = Bunny.new("amqp://guest:guest@localhost:5672")
conn.start

ch = conn.create_channel
x = ch.fanout('msgs')

ch.queue('q2').bind(x).subscribe(block: true) do |info, meta, payload|
  puts "payload: Q2 > #{payload}"
end