lib/fluent/plugin/out_scribe.rb in fluent-plugin-scribe-0.10.11 vs lib/fluent/plugin/out_scribe.rb in fluent-plugin-scribe-0.10.12

- old
+ new

@@ -27,10 +27,14 @@ config_param :remove_prefix, :string, :default => nil config_param :add_newline, :bool, :default => false config_param :default_category, :string, :default => 'unknown' config_param :format_to_json, :bool, :default => false + unless method_defined?(:log) + define_method(:log) { $log } + end + def initialize require 'thrift' $:.unshift File.join(File.dirname(__FILE__), 'thrift') require 'fb303_types' require 'fb303_constants' @@ -100,10 +104,10 @@ entry.message = message.force_encoding('ASCII-8BIT') entries << entry end - $log.debug "Writing #{entries.count} entries to scribe" + log.debug "Writing #{entries.count} entries to scribe" client.Log(entries) ensure transport.close end end