*/
    public GenerateThumbnailJob() {
        super();
    }

    /**
     * Sets the number of threads to use for thumbnail generation.
     *
     * @param numOfThreads the number of threads
     * @return this job instance for method chaining
     */
    public GenerateThumbnailJob numOfThreads(final int numOfThreads) {
        this.numOfThreads = numOfThreads;
        return this;
    }

     */
    private static boolean isNoneEnv() {
        return System.getProperty("lasta.env") == null;
    }

    /**
     * Gets the port number for the Tomcat server from system properties.
     *
     * @return the port number (default 8080 if not specified)
     */
    protected static int getPort() {
        final String value = System.getProperty(FESS_PORT);
        if (value != null) {

     * @param encType Encryption type
     * @param encryptedData Encrypted data
     * @param unknownTag Optional unknown tag number to test error handling
     * @return A byte array representing the ticket
     * @throws IOException on encoding error
     */
    private byte[] createTestTicketBytes(Number version, String realm, String principalName, int encType, byte[] encryptedData,
            Integer unknownTag) throws IOException {

    @Max(value = 2147483647)
    @ValidateTypeFailure
    public Integer depth;

    /** The maximum number of documents to access during crawling (0 means unlimited). */
    @Min(value = 0)
    @Max(value = 9223372036854775807L)
    @ValidateTypeFailure
    public Long maxAccessCount;

    /** The number of threads to use for crawling (required, 1 to 2147483647). */
    @Required
    @Min(value = 1)

	// otherwise, ok will be false and conn will be nil.
	conn, ok := tx.ConnPool.(*gorm.PreparedStmtDB)
	// Get the number of statement keys stored in the PreparedStmtDB.
	lens := len(conn.Stmts.Keys())
	// Check if the number of stored statement keys is 0.
	if lens == 0 {
		// If the number is 0, it means there are no statements stored in the LRU cache.
		// The test fails and an error message is output.

        this.ampersandStr = ampersandStr;
    }

    /**
     * Gets the maximum number of duplicated paths to attempt.
     *
     * @return the maximum duplicated path count
     */
    public int getMaxDuplicatedPath() {
        return maxDuplicatedPath;
    }

    /**
     * Sets the maximum number of duplicated paths to attempt.
     *

						return err
					}
					buf := bytes.NewBuffer(nil)
					if _, err = msgp.CopyToJSON(buf, bytes.NewReader(b)); err != nil {
						return err
					}

					dec := json.NewDecoder(buf)
					// Use number to preserve integers.
					dec.UseNumber()
					var htr map[string]any
					if err = dec.Decode(&htr); err != nil {
						return err
					}
					ht[file.Name] = htr
				}
			}

        maxRedirectCount = fessConfig.getIndexerDataMaxRedirectCountAsInteger();
    }

    /**
     * Creates a new fixed thread pool executor with the specified number of threads.
     *
     * @param nThreads the number of threads in the pool
     * @return a new ThreadPoolExecutor configured for this callback
     */
    protected ExecutorService newFixedThreadPool(final int nThreads) {

        /**
         * Default constructor for SamrSamArray.
         */
        public SamrSamArray() {
            // Default constructor
        }

        /** The number of entries in the array */
        public int count;
        /** The array of SAM entries */
        public SamrSamEntry[] entries;

        @Override
        public void encode(NdrBuffer _dst) throws NdrException {

        /**
         * Default constructor for SamrSamArray.
         */
        public SamrSamArray() {
            // Default constructor
        }

        /** The number of entries in the array */
        public int count;
        /** The array of SAM entries */
        public SamrSamEntry[] entries;

        @Override
        public void encode(NdrBuffer _dst) throws NdrException {