Sha256: ca0b6aeeddabc61d553fc591188ccc16d7fe808864fb5bafb4f0a605005014c5
Contents?: true
Size: 880 Bytes
Versions: 11
Compression:
Stored size: 880 Bytes
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Rabbit
module Publisher
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
# This publisher send and read an message in admin queues
class PublisherAdmin < Publisher
# Intialize an queue non eclusive for admin/monitor API with Janus
def initialize(exchange)
@reply = exchange.queue(queue_from)
super(exchange)
subscribe_to_queue
end
# Send an message to queue and waiting a response
def send_a_message(request)
super(request)
return_response
end
private
attr_reader :reply
# Define queue used for posting a message to API admin
def queue_from
Tools::Config.instance.options['queues']['admin']['queue_from']
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems