Method: MessageBus::Implementation#after_fork

Defined in:
lib/message_bus.rb

#after_fork ⇒ Object 



338
339
340
341
342
343
 
# File 'lib/message_bus.rb', line 338

def after_fork
  reliable_pub_sub.after_fork
  ensure_subscriber_thread
  # will ensure timer is running
  timer.queue {}
end