Sha256: e9c47365318598f5e227dd6f421288a8c1116c2e5efc4c055156155fd12c5544
Contents?: true
Size: 1.06 KB
Versions: 5
Compression:
Stored size: 1.06 KB
Contents
# frozen_string_literal: true
require 'rails'
require 'action_view'
module RubyRabbitmqJanus
# @author VAILLANT Jeremy <jeremy.vaillant@dazzl.tv>
# # Rails
#
# Use option to rails for prepare application with RRJ.
# Initialize public queue to Janus instance.
class Rails < ::Rails::Engine
config.after_initialize do
Log.debug '[RRJ] After initializer'
require File.join(Dir.pwd,
RubyRabbitmqJanus::Tools::Config.instance.listener_path)
require File.join(Dir.pwd,
RubyRabbitmqJanus::Tools::Config.instance.listener_admin_path)
process = RubyRabbitmqJanus::Process::Concurrencies
Log.info '[RRJ] Listen public queue in thread'
actions = RubyRabbitmqJanus::ActionEvents.new.actions
process::Event.instance.run(&actions)
Log.info '[RRJ] Listen admin queue in thread'
admin_actions = RubyRabbitmqJanus::ActionAdminEvents.new.actions
process::EventAdmin.instance.run(&admin_actions)
end
end
end
require ::File.expand_path('config/environment', Dir.pwd)
Version data entries
5 entries across 5 versions & 1 rubygems