module RJ

Public gem API.

Constants

VERSION

Attributes

logger[W]

Public Class Methods

before_process_message(&block) click to toggle source
# File lib/rabbit_jobs.rb, line 38
def before_process_message(&block)
  fail unless block_given?
  @before_process_message_callbacks ||= []
  @before_process_message_callbacks << block
end
config() click to toggle source
# File lib/rabbit_jobs.rb, line 60
def config
  @configuration ||= load_config
end
configure() { |configuration| ... } click to toggle source

Configuration

# File lib/rabbit_jobs.rb, line 55
def configure
  @configuration ||= Configuration.new
  yield @configuration if block_given?
end
load_config(config_file = nil) click to toggle source
# File lib/rabbit_jobs.rb, line 64
def load_config(config_file = nil)
  @configuration ||= nil

  config_file ||= defined?(Rails) && Rails.respond_to?(:root) && Rails.root.join('config/rabbit_jobs.yml')
  if config_file
    if File.exist?(config_file)
      @configuration ||= Configuration.new
      @configuration.load_file(config_file)
    end
  end

  unless @configuration
    configure do |c|
      c.server 'amqp://localhost'
    end
  end

  @configuration
end
logger() click to toggle source
# File lib/rabbit_jobs.rb, line 28
def logger
  unless @logger
    @logger = Logger.new($stdout)
    @logger.level = Logger::INFO
    @logger.formatter = nil
    @logger.progname = 'rj'
  end
  @logger
end
run_before_process_message_callbacks() click to toggle source
# File lib/rabbit_jobs.rb, line 44
def run_before_process_message_callbacks
  @before_process_message_callbacks ||= []
  @before_process_message_callbacks.each do |callback|
    return false unless callback.call
  end
  true
rescue
  false
end