Class: RubyRabbitmqJanus::Janus::TransactionSession

Inherits:
Transaction
  • Object
show all
Defined in:
lib/rrj/janus/transactions/session.rb

Overview

This class work with janus and send a series of message for session level

Author:

Direct Known Subclasses

TransactionHandle

Instance Attribute Summary

Attributes inherited from Transaction

#handle, #publish, #rabbit, #response, #session

Instance Method Summary collapse

Methods inherited from Transaction

#choose_queue, #connect, #create_handle, #initialize, #send_a_message

Constructor Details

This class inherits a constructor from RubyRabbitmqJanus::Janus::Transaction

Instance Method Details

#session_connect(exclusive) ⇒ Object

Connect to session and post an message



9
10
11
12
13
14
 
# File 'lib/rrj/janus/transactions/session.rb', line 9

def session_connect(exclusive)
  rabbit.transaction_short do
    choose_queue(exclusive)
    send_a_message { yield }
  end
end