lib/fluent/plugin/out_newrelic.rb in fluent-plugin-newrelic-0.2.6 vs lib/fluent/plugin/out_newrelic.rb in fluent-plugin-newrelic-0.2.7
- old
+ new
@@ -42,9 +42,15 @@
config_set_default :chunk_keys, ['timestamp']
end
define_method('log') {$log} unless method_defined?(:log)
+ # This tells Fluentd that it can run this output plugin in multiple workers.
+ # Our plugin has no interactions with other processes
+ def multi_workers_ready?
+ true
+ end
+
def configure(conf)
super
# create initial sockets hash and socket based on config param
@end_point = URI.parse(@base_uri)