Merge pull request #1508 from tatsu-yam/feature/v012_flush_labels

root_agent flush labels
fluent · Mar 21, 2017 · d8df66c · d8df66c
2 parents 62628ea + 4c33b54
commit d8df66c
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/fluent/root_agent.rb b/lib/fluent/root_agent.rb
@@ -138,6 +138,11 @@ def shutdown
       super
     end
 
+    def flush!
+      super
+      @labels.each{ |name, label| label.flush! }
+    end
+
     def suppress_interval(interval_time)
       @suppress_emit_error_log_interval = interval_time
       @next_emit_error_log_time = Time.now.to_i