Rabbit MQ Handler

rabbit_mq_handler.rb

#!/usr/bin/env ruby

ENV['RAILS_ENV'] ||= 'development'

require_relative '../config/environment'

include RabbitMqHelper

def files_to_reopen
  @files_to_reopen ||= []
end

def collect_open_files
  # NOTE: Logging fix for daemons under Rails
  ObjectSpace.each_object(File) do |file|
    files_to_reopen << file unless file.closed?
  end
end

def reopen_initial_files
  # NOTE: Logging fix for daemons under Rails
  files_to_reopen.each do |file|
    file.reopen file.path, 'a+'
    file.sync = true
  end
end

def establish_active_record_connection
  defined?(ActiveRecord::Base) && ActiveRecord::Base.establish_connection
end

collect_open_files

Daemons.run_proc('rabbit_mq', multiple: false, backtrace: true, log_output: true) do
  begin
    establish_active_record_connection

    reopen_initial_files

    handle_subscription
  rescue StandardError => e
    puts e.message
    puts e.backtrace
  end
end