Class: RubyRabbitmqJanus::Rabbit::Publisher::PublisherAdmin

Inherits:
RubyRabbitmqJanus::Rabbit::Publisher show all
Defined in:
lib/rrj/rabbit/publish/admin.rb

Overview

This publisher send and read an message in admin queues

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(exchange) ⇒ PublisherAdmin

Intialize an queue non eclusive for admin/monitor API with Janus



10
11
12
13
 
# File 'lib/rrj/rabbit/publish/admin.rb', line 10

def initialize(exchange)
  super(exchange)
  @reply = exchange.queue(queue_from)
end

Instance Attribute Details

#reply ⇒ Object (readonly, private)

Returns the value of attribute reply.



17
18
19
 
# File 'lib/rrj/rabbit/publish/admin.rb', line 17

def reply
  @reply
end

Instance Method Details

#queue_from ⇒ Object (private)

Define queue used for posting a message to API admin



20
21
22
 
# File 'lib/rrj/rabbit/publish/admin.rb', line 20

def queue_from
  Tools::Config.instance.options['queues']['admin']['queue_from']
end