class Fluent::TcpInput

end
end
Coolio::TCPServer.new(@bind, @port, Handler, method(:on_message))
$log.debug “listening fluent socket on #{@bind}:#{@port}”
def listen
end
super
def configure(conf)
config_param :bind, :string, :default => ‘0.0.0.0’
config_param :port, :integer, :default => DEFAULT_LISTEN_PORT
Plugin.register_input(‘tcp’, self)
class TcpInput < StreamInput
ForwardInput is backward compatible with TcpInput
obsolete

def initialize 

def initialize
  super
  $log.warn "'tcp' input is obsoleted and will be removed soon. Use 'forward' instead."
end