class Fluent::UnixInput
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
Fluent::PluginLoggerMixin#configure
# File lib/fluent/plugin/in_unix.rb, line 185 def configure(conf) super #log.warn "'unix' input is obsoleted and will be removed. Use 'forward' instead." end
listen()
click to toggle source
# File lib/fluent/plugin/in_unix.rb, line 190 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