Method: MessageBus::Implementation#after_fork

Defined in:
lib/message_bus.rb

#after_fork ⇒ Object 



298
299
300
301
 
# File 'lib/message_bus.rb', line 298

def after_fork
  reliable_pub_sub.after_fork
  ensure_subscriber_thread
end