class Fluent::UnixInput

def configure(conf)
  super
  #log.warn "'unix' input is obsoleted and will be removed. Use 'forward' instead."
end

def listen
  if File.exist?(@path)
    File.unlink(@path)
  end
  FileUtils.mkdir_p File.dirname(@path)
  log.info "listening fluent socket on #{@path}"
  s = Coolio::UNIXServer.new(@path, Handler, log, method(:on_message))
  s.listen(@backlog) unless @backlog.nil?
  s
end