out_stdout uses logger instead of STDOUT

netconstructor · Apr 30, 2012 · dcdf407 · dcdf407
1 parent 9725ad1
commit dcdf407
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/lib/fluent/log.rb b/lib/fluent/log.rb
@@ -227,6 +227,14 @@ def puts(msg)
     nil
   end
 
+  def write(data)
+    @out.write(data)
+  end
+
+  def flush
+    @out.flush
+  end
+
   private
   def event(level, args)
     time = Time.now

diff --git a/lib/fluent/plugin/out_stdout.rb b/lib/fluent/plugin/out_stdout.rb
@@ -21,13 +21,11 @@ module Fluent
 class StdoutOutput < Output
   Plugin.register_output('stdout', self)
 
-  config_param :autoflush, :bool, :default => false
-
   def emit(tag, es, chain)
     es.each {|time,record|
-      puts "#{Time.at(time).localtime} #{tag}: #{Yajl.dump(record)}"
+      $log.write "#{Time.at(time).localtime} #{tag}: #{Yajl.dump(record)}\n"
     }
-    STDOUT.flush if @autoflush
+    $log.flush
 
     chain.next
   end