class Fluent::DetachProcessManager::Forwarder

Public Class Methods

new(w) click to toggle source
# File lib/fluent/process.rb, line 219
def initialize(w)
  @w = w
end

Public Instance Methods

emit(tag, es) click to toggle source
# File lib/fluent/process.rb, line 223
def emit(tag, es)
  ms = es.to_msgpack_stream
  #[tag, ms].to_msgpack(@w)  # not thread safe
  @w.write [tag, ms].to_msgpack
end