blob: 121de32395824079637f4ff215dc5d40ab834592 (
plain)
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
29
30
31
32
|
#!/usr/bin/env ruby
## encoding: utf-8
require "bunny"
if ARGV.empty?
ARGV.push('#')
end
connection = Bunny.new
connection.start
channel = connection.create_channel
exchange = channel.topic("chitchat")
queue = channel.queue("", exclusive: true)
ARGV.each do |username|
queue.bind(exchange, routing_key: username)
end
puts " [*] Waiting for gossip. To exit press CTRL+C"
begin
queue.subscribe(block: true) do |delivery_info, properties, body|
puts " [x] #{delivery_info.routing_key}:#{body}"
message = "#{delivery_info.routing_key} says #{body}"
system("say '#{message}'")
end
rescue Interrupt => _
channel.close
connection.close
end
|
