Class: RubyRabbitmqJanus::Rabbit::Publisher::JanusInstance

Inherits:
Object
  • Object
show all
Defined in:
lib/rrj/rabbit/publisher/janus_instance.rb

Overview

Publisher to queue janus-instance

Instance Method Summary collapse

Constructor Details

#initialize ⇒ JanusInstance

Returns a new instance of JanusInstance.



8
9
10
11
12
 
# File 'lib/rrj/rabbit/publisher/janus_instance.rb', line 8

def initialize
  @rabbit = RubyRabbitmqJanus::Rabbit::Connect.new
rescue
  raise Errors::Rabbit::Publisher::JanusInstance::Initialize
end

Instance Method Details

#publish(data) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
 
# File 'lib/rrj/rabbit/publisher/janus_instance.rb', line 14

def publish(data)
  @rabbit.start
  channel = @rabbit.channel
  queue = channel.queue(Tools::Config.instance.queue_janus_instance)
  channel.default_exchange.publish(data.to_json,
                                   routing_key: queue.name)
  @rabbit.close
rescue
  raise Errors::Rabbit::Publisher::JanusInstance::Publish
end