# File lib/fluent/plugin/in_stream.rb, line 181 def configure(conf) super #log.warn "'unix' input is obsoleted and will be removed. Use 'forward' instead." end
# File lib/fluent/plugin/in_stream.rb, line 186 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