Contents

# frozen_string_literal: true

module RubyRabbitmqJanus
  module Janus
    module Transactions
      # @author VAILLANT Jeremy <[e-mail]>
      #
      # # Manage a transaction
      #
      # Manage a transaction with message if contains a session identifier
      class Session < Transaction
        # Initialize a transaction with handle
        #
        # @param [Fixnum] session
        #   Use a session identifier for created message
        def initialize(exclusive, session)
          super(session)
          @exclusive = exclusive
        rescue
          raise Errors::Janus::TransactionSession::Initialize
        end

        # Opening a short transaction with rabbitmq and close when is ending
        #
        # @yield Send a message to Janus
        def connect
          rabbit.transaction_short do
            choose_queue
            yield
          end
        rescue
          raise Errors::Janus::TransactionSession::Connect
        end

        def publish_message(type, options = {})
          msg = Janus::Messages::Standard.new(type, opts.merge!(options))
          response = read_response(publisher.publish(msg))
          Janus::Responses::Standard.new(response)
        rescue
          raise Errors::Janus::TransactionSession::PublishMessage
        end

        private

        def opts
          { 'session_id' => session }
        end
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
ruby_rabbitmq_janus-2.1.0.pre.130	lib/rrj/janus/transactions/session.rb
ruby_rabbitmq_janus-2.1.0.pre.129	lib/rrj/janus/transactions/session.rb
ruby_rabbitmq_janus-2.1.0.pre.128	lib/rrj/janus/transactions/session.rb