Sha256: da6e076c60e72bb4a6a85913cc8bae5097ebfda0601c30a87cdfb0cbad5ef19f
Contents?: true
Size: 534 Bytes
Versions: 12
Compression:
Stored size: 534 Bytes
Contents
# frozen_string_literal: true
module RubyRabbitmqJanus
module Janus
module Transactions
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
# This class work with janus and send a series of message for session level
class Session < Transaction
# Connect to session and post an message
def session_connect(exclusive)
rabbit.transaction_short do
choose_queue(exclusive)
send_a_message(exclusive) { yield }
end
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems