1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
#!/usr/bin/ruby
require 'bunny'
connection = Bunny.new('amqp://localhost').tap do |c|
c.start
end
msg = "HELLO WORLD!"
# send a message
send_channel = connection.create_channel
send_queue = send_channel.queue('ruby-bunny-autopkgtest')
send_queue.publish(msg)
puts 'I: sent message: %s' % msg
# receive message
receive_channel = connection.create_channel
receive_queue = send_channel.queue('ruby-bunny-autopkgtest')
info, medatata, payload = receive_queue.pop
puts 'I: received message: %s' % payload
fail("%s != %s" % [msg, payload]) if msg != payload
|
