Module: RabbitJobs::MainLoop
Overview
Main process loop.
Instance Method Summary collapse
- #log_daemon_error(error) ⇒ Object
- #main_loop ⇒ Object
- #shutdown ⇒ Object
- #shutdown! ⇒ Object
- #startup ⇒ Object
Instance Method Details
#log_daemon_error(error) ⇒ Object
37 38 39 40 41 42 43 |
# File 'lib/rabbit_jobs/main_loop.rb', line 37 def log_daemon_error(error) return unless RabbitJobs.logger RabbitJobs.logger.fatal error ensure abort(error.) end |
#main_loop ⇒ Object
23 24 25 26 27 28 29 30 31 32 33 34 35 |
# File 'lib/rabbit_jobs/main_loop.rb', line 23 def main_loop loop do sleep 0.5 next unless @shutdown RabbitJobs.logger.info 'Stopping.' if defined?(amqp_connection) # in worker only amqp_cleanup end yield if block_given? return true end end |
#shutdown ⇒ Object
15 16 17 |
# File 'lib/rabbit_jobs/main_loop.rb', line 15 def shutdown @shutdown = true end |
#shutdown! ⇒ Object
19 20 21 |
# File 'lib/rabbit_jobs/main_loop.rb', line 19 def shutdown! shutdown end |
#startup ⇒ Object
4 5 6 7 8 9 10 11 12 13 |
# File 'lib/rabbit_jobs/main_loop.rb', line 4 def startup $stdout.sync = true @shutdown = false Signal.trap('TERM') { shutdown } Signal.trap('INT') { shutdown! } true end |