Contents

require 'active_support/all'
require 'active_model'
require 'avro'
require 'bunny'
require 'yaml'
require_relative './dsl'
require 'rabbit_feed/version'
require 'rabbit_feed/client'
require 'rabbit_feed/configuration'
require 'rabbit_feed/event'
require 'rabbit_feed/connection'
require 'rabbit_feed/consumer_connection'
require 'rabbit_feed/consumer'
require 'rabbit_feed/event_routing'
require 'rabbit_feed/producer_connection'
require 'rabbit_feed/producer'
require 'rabbit_feed/event_definitions'
require 'rabbit_feed/testing_support'
require 'rabbit_feed/version'
require 'rabbit_feed/json_log_formatter'

module RabbitFeed
  extend self
  class Error < StandardError; end
  class ConfigurationError < Error; end
  class RoutingError < Error; end
  class ReturnedMessageError < Error; end

  attr_accessor :log, :environment, :configuration_file_path, :application

  def configuration
    @configuration ||= (Configuration.load configuration_file_path, environment, application)
  end

  def exception_notify exception
    if defined? Airbrake
      (Airbrake.notify_or_ignore exception) if Airbrake.configuration.public?
    end
  end

  def default_logger
    if File.directory? 'log'
      Logger.new 'log/rabbit_feed.log', 10, 100.megabytes
    else
      Logger.new STDOUT
    end.tap do |log|
      log.formatter = RabbitFeed::JsonLogFormatter
      log.level     = Logger::INFO
    end
  end

  def set_defaults
    self.log                     = default_logger
    self.configuration_file_path = 'config/rabbit_feed.yml'
    self.environment             = ENV['RAILS_ENV'] || ENV['RACK_ENV'] || 'development'
  end
  private :set_defaults

  set_defaults
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
rabbit_feed-2.3.7	lib/rabbit_feed.rb
rabbit_feed-2.3.6	lib/rabbit_feed.rb
rabbit_feed-2.3.5	lib/rabbit_feed.rb
rabbit_feed-2.3.4	lib/rabbit_feed.rb
rabbit_feed-2.3.3	lib/rabbit_feed.rb