lib/fluent/plugin/out_flowcounter.rb in fluent-plugin-flowcounter-1.2.0 vs lib/fluent/plugin/out_flowcounter.rb in fluent-plugin-flowcounter-1.3.0
- old
+ new
@@ -75,9 +75,13 @@
@counts = count_initialized
@mutex = Mutex.new
end
+ def multi_workers_ready?
+ true
+ end
+
def start
super
@initializer.call
timer_execute(:out_flowcounter_watcher, 0.5) do