Module: RabbitJobs
- Defined in:
- lib/rabbit_jobs.rb,
lib/rabbit_jobs/job.rb,
lib/rabbit_jobs/worker.rb,
lib/rabbit_jobs/version.rb,
lib/rabbit_jobs/main_loop.rb,
lib/rabbit_jobs/publisher.rb,
lib/rabbit_jobs/scheduler.rb,
lib/rabbit_jobs/configuration.rb,
lib/rabbit_jobs/amqp_transport.rb,
lib/rabbit_jobs/publisher/amqp.rb,
lib/rabbit_jobs/publisher/base.rb,
lib/rabbit_jobs/publisher/sync.rb,
lib/rabbit_jobs/publisher/test.rb,
lib/rabbit_jobs/consumer/job_consumer.rb
Overview
Defined Under Namespace
Modules: AmqpTransport, Consumer, Job, MainLoop
Classes: Configuration, Publisher, Scheduler, Worker
Constant Summary
collapse
- VERSION =
'0.12.2'
Class Attribute Summary collapse
Class Method Summary
collapse
Class Attribute Details
.logger ⇒ Object
28
29
30
31
32
33
34
35
36
|
# 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
|
Class Method Details
.before_process_message(&block) ⇒ Object
38
39
40
41
42
|
# 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 ⇒ Object
60
61
62
|
# File 'lib/rabbit_jobs.rb', line 60
def config
@configuration ||= load_config
end
|
55
56
57
58
|
# File 'lib/rabbit_jobs.rb', line 55
def configure
@configuration ||= Configuration.new
yield @configuration if block_given?
end
|
.load_config(config_file = nil) ⇒ Object
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
# 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
|
.run_before_process_message_callbacks ⇒ Object
44
45
46
47
48
49
50
51
52
|
# 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
|