Commit 411ff5e
Changed files (2)
lib
6-chit-chat
lib/6-chit-chat/publish.rb
@@ -3,7 +3,7 @@
require "bunny"
-connection = Bunny.new
+connection = Bunny.new(host: ENV.fetch('RABBIT_HOST', 'localhost'))
connection.start
channel = connection.create_channel
lib/6-chit-chat/subscribe.rb
@@ -3,17 +3,14 @@
require "bunny"
-if ARGV.empty?
- ARGV.push('#')
-end
-
-connection = Bunny.new
+connection = Bunny.new(host: ENV.fetch('RABBIT_HOST', 'localhost'))
connection.start
channel = connection.create_channel
exchange = channel.topic("chitchat")
queue = channel.queue("", exclusive: true)
+ARGV.push('#') if ARGV.empty?
ARGV.each do |username|
queue.bind(exchange, routing_key: username)
end