lib/rrj/rabbit/publisher/admin.rb in ruby_rabbitmq_janus-4.0.0.pre.949167646 vs lib/rrj/rabbit/publisher/admin.rb in ruby_rabbitmq_janus-4.0.0.pre.1001043172
- old
+ new
@@ -10,11 +10,10 @@
class Admin < Base
# Initialize an queue non eclusive for admin/monitor API with Janus
#
# @param [String] exchange Exchange used for the transaction
def initialize(exchange)
- @reply = exchange.queue('', exclusive: true)
- # @reply = exchange.queue(Tools::Config.instance.queue_admin_from)
+ @reply = exchange.queue(Tools::Config.instance.queue_admin_from)
super(exchange)
subscribe_to_queue
end
# Send an message to queue and waiting a response