Module: Fleck::Core::Consumer::Base::InstanceMethods
- Defined in:
- lib/fleck/core/consumer/base.rb
Overview
Defines instance methods to import when ‘Autostart` module is imported.
Instance Method Summary collapse
Instance Method Details
#autostart? ⇒ Boolean
86 87 88 |
# File 'lib/fleck/core/consumer/base.rb', line 86 def autostart? configs[:autostart].nil? || configs[:autostart] end |
#start ⇒ Object
90 91 92 93 94 95 |
# File 'lib/fleck/core/consumer/base.rb', line 90 def start logger.info "Launching #{self.class.to_s.color(:yellow)} consumer ..." connect! create_channel! subscribe! end |
#terminate ⇒ Object
97 98 99 100 101 102 103 104 105 106 |
# File 'lib/fleck/core/consumer/base.rb', line 97 def terminate pause return if channel.nil? || channel.closed? channel.close logger.info 'Consumer successfully terminated.' self.class.on_terminate(self) end |