Class: RubyRabbitmqJanus::Janus::Transactions::Admin

Inherits:
Session show all
Defined in:
lib/rrj/janus/transactions/admin.rb

Overview

This class work with janus and send a series of message

Instance Method Summary collapse

Constructor Details

#initialize(session) ⇒ Admin

Returns a new instance of Admin.



12
13
14
15
16
 
# File 'lib/rrj/janus/transactions/admin.rb', line 12

def initialize(session)
  super(true, session)
rescue
  raise Errors::Janus::TransactionAdmin::Initialize
end

Instance Method Details

#connect ⇒ Object

Begin connection with RabbitMQ



19
20
21
22
23
24
25
26
 
# File 'lib/rrj/janus/transactions/admin.rb', line 19

def connect
  rabbit.transaction_short do
    @publisher = Rabbit::Publisher::Admin.new(rabbit.channel)
    yield
  end
rescue
  raise Errors::Janus::TransactionAdmin::Connect
end

#publish_message(type, options = {}) ⇒ Object

Write a message in queue in RabbitMQ



29
30
31
32
33
34
35
 
# File 'lib/rrj/janus/transactions/admin.rb', line 29

def publish_message(type, options = {})
  msg = Janus::Messages::Admin.new(type, options.merge(opts2))
  response = read_response(publisher.publish(msg))
  Janus::Responses::Admin.new(response)
rescue
  raise Errors::Janus::TransactionAdmin::PublishMessage
end