Module: Harmoniser::Subscriber

Includes:
Connectable
Defined in:
lib/harmoniser/subscriber.rb,
lib/harmoniser/subscriber/registry.rb

Defined Under Namespace

Modules: ClassMethods Classes: MissingConsumerDefinition, Registry

Constant Summary

Constants included from Connectable

Connectable::MUTEX

Class Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



90
91
92
93
94
95
 
# File 'lib/harmoniser/subscriber.rb', line 90

def included(base)
  base.const_set(:HARMONISER_SUBSCRIBER_MUTEX, Mutex.new)
  base.private_constant(:HARMONISER_SUBSCRIBER_MUTEX)
  registry << base
  base.extend(ClassMethods)
end

.registry ⇒ Object 



97
98
99
 
# File 'lib/harmoniser/subscriber.rb', line 97

def registry
  @registry ||= Registry.new
end