class Fluent::TcpInput

def listen(callback)
  log.info "listening tcp socket on #{@bind}:#{@port}"
  Coolio::TCPServer.new(@bind, @port, SocketUtil::TcpHandler, log, @delimiter, callback, !!@source_hostname_key)
end