Created

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist

Example 4 for "Messaging for Rubyists"

View example4.rb
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28
require 'bunny'
 
b = Bunny.new({}, {:spec => "09"})
b.start
 
# setup
e = b.exchange("exchange-04")
 
q1 = b.queue("queue-04-01")
q1.bind e
 
q2 = b.queue("queue-04-02")
q2.bind e
 
# producer
e.publish("Message Body")
 
# consumer 1
msg = q1.pop
puts "CONSUMER1: This is the message: #{msg}"
puts "CONSUMER1: This is the payload: #{msg[:payload]}"
 
# consumer 2
msg = q2.pop
puts "CONSUMER2: This is the message: #{msg}"
puts "CONSUMER2: This is the payload: #{msg[:payload]}"
 
b.stop
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Something went wrong with that request. Please try again.