Method: MessageBus::Implementation#initialize

Defined in:
lib/message_bus.rb

#initialize ⇒ Object 



38
39
40
41
42
43
44
45
46
 
# File 'lib/message_bus.rb', line 38

def initialize
  @config = {}
  @mutex = Synchronizer.new
  @off = false
  @off_disable_publish = false
  @destroyed = false
  @timer_thread = nil
  @subscriber_thread = nil
end