Sha256: 3ea7562eb852a768c89d2ef88b1c86cc17e74019fb6d8ef411ec7eb20897e9aa
Contents?: true
Size: 908 Bytes
Versions: 22
Compression:
Stored size: 908 Bytes
Contents
# 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
rescue => exception
Log.fatal '!! Fail to start RRJ Thread Janus Instance management !!'
Log.fatal exception
exit 1
end
Version data entries
22 entries across 22 versions & 1 rubygems