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