# frozen_string_literal: true # Loads files RRJ and write first message in log, # then initialize binary require 'rrj/rails' # defined?(::Rails::Engine) # require File.join(File.dirname(__FILE__), '..', '..', 'binary') begin # bin = RubyRabbitmqJanus::Binary.new # Log.info \ # 'Prepare to listen events in queue : ' + \ # RubyRabbitmqJanus::Tools::Config.instance.queue_janus_instance # rabbit = RubyRabbitmqJanus::Rabbit::Connect.new # rabbit.start # listener = RubyRabbitmqJanus::Rabbit::Listener::JanusInstance.new(rabbit) # Log.info 'Loop events provided by Janus queues' # loop do # listener.listen_events do |event, response| # Log.debug "Event : #{event}" # Log.debug "Response : #{response.to_hash}" # bin.update_instance(response.to_hash) # end # end Log.info 'Listen Public queue to Janus' loop {} rescue => exception Log.fatal '!! Fail to start RRJ Thread Janus Instance management !!' Log.fatal exception exit 1 end