Class: Synapse::ProcessManager::ProcessManager Abstract
- Inherits:
-
Object
- Object
- Synapse::ProcessManager::ProcessManager
- Includes:
- EventBus::EventListener
- Defined in:
- lib/synapse/process_manager/process_manager.rb
Overview
This class is abstract.
Represents a mechanism for managing the lifeycle and notification of process instances
Direct Known Subclasses
Instance Attribute Summary collapse
-
#suppress_exceptions ⇒ Boolean
Returns true if exceptions will be logged silently.
Instance Method Summary collapse
- #initialize(repository, factory, lock_manager, *process_types) ⇒ undefined constructor
- #notify(event) ⇒ undefined
Constructor Details
#initialize(repository, factory, lock_manager, *process_types) ⇒ undefined
16 17 18 19 20 21 22 23 24 |
# File 'lib/synapse/process_manager/process_manager.rb', line 16 def initialize(repository, factory, lock_manager, *process_types) @repository = repository @factory = factory @lock_manager = lock_manager @process_types = process_types.flatten @logger = Logging.logger[self.class] @suppress_exceptions = true end |
Instance Attribute Details
#suppress_exceptions ⇒ Boolean
Returns true if exceptions will be logged silently
9 10 11 |
# File 'lib/synapse/process_manager/process_manager.rb', line 9 def suppress_exceptions @suppress_exceptions end |
Instance Method Details
#notify(event) ⇒ undefined
28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/synapse/process_manager/process_manager.rb', line 28 def notify(event) @process_types.each do |process_type| correlation = extract_correlation process_type, event if correlation current = notify_current_processes process_type, event, correlation if should_start_new_process process_type, event, current start_new_process process_type, event, correlation end end end end |