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
# 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