Method: Fluent::FluentLogEventRouter#stop

Defined in:
lib/fluent/fluent_log_event_router.rb

#stop ⇒ Object 



123
124
125
126
127
 
# File 'lib/fluent/fluent_log_event_router.rb', line 123

def stop
  @event_queue.push(STOP)
  # there is no problem calling Thread#join multiple times.
  @thread && @thread.join
end