}

    /**
     * Internal method to destroy a specific JobProcess.
     * Handles cleanup of streams, threads, and process termination.
     *
     * @param sessionId unique identifier for the process session
     * @param jobProcess the JobProcess to destroy
     * @return exit code of the destroyed process, or -1 if the process was null or could not be destroyed
     */

        if (commandDestroyTimeoutStr != null) {
            commandDestroyTimeout = Long.parseLong(commandDestroyTimeoutStr);
        }
    }

    /**
     * Destroys the command generator and cleanup resources.
     */
    @Override
    public void destroy() {
        destoryTimer.cancel();
        destoryTimer = null;
    }

            }

            // expanded distro
            configurations.create("expanded-${testArchiveProjectName}")
            def expandedTask = tasks.register("buildBwcExpandedTask", Copy) {
                from('bwc-marker.txt')
                into('build/install/elastic-distro')
            }
            artifacts {

        );
    }

    public void testTypeDefault() {
        ElasticsearchDistribution distro = checkDistro(createProject(null), "testdistro", "5.0.0", null, Platform.LINUX, true);
        assertEquals(distro.getType(), ElasticsearchDistributionTypes.ARCHIVE);
    }

    public void testPlatformDefault() {
        ElasticsearchDistribution distro = checkDistro(
            createProject(null),
            "testdistro",
            "5.0.0",

     */
    @PostConstruct
    public void init() {
        fesenClient.addOnConnectListener(() -> createMapping("queue"));
    }

    /**
     * Destroys the service.
     */
    @PreDestroy
    public void destroy() {
        sessionCache.entrySet().stream().map(e -> e.getValue().waitingQueue).forEach(q -> q.forEach(urlQueue -> {
            try {
                insert(urlQueue);

        helper.init();
        // destroy() cancels the task and flushes; should not throw
        helper.destroy();
    }

    @Test
    public void test_destroy_beforeInit() {
        LogNotificationHelper helper = new LogNotificationHelper();
        // destroy() without init() should not throw NPE because of null checks
        helper.destroy();
    }

    @Test

        }
    }

    @Override
    public void destroy() throws DestroyFailedException {
        if (!destroyed) {
            boolean failedToDestroy = false;
            Exception destroyException = null;

            try {
                // Mark as destroyed first to prevent further operations
                destroyed = true;

                // Try to destroy master key if it implements Destroyable

                ThreadUtil.sleep(RandomUtils.nextLong(minSleep, maxSleep));
                retryCount++;
            }
        }
    }

    /**
     * Destroys the client and closes connections.
     */
    @PreDestroy
    public void destroy() {
        if (client != null) {
            try {
                client.close();
            } catch (final OpenSearchException e) {

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

    /**
     * Destroys this thumbnail generator and releases any resources.
     * This implementation is empty as no cleanup is required.
     */
    @Override
    public void destroy() {
    }

    /**
     * Creates a thumbnail generation task for the specified document.
     *

        // Initialize without container
        emptyGenerator = new EmptyGenerator();

        // Test that destroy method can be called without error
        emptyGenerator.destroy();
        // Call destroy multiple times to ensure it's safe
        emptyGenerator.destroy();
        emptyGenerator.destroy();
    }

    @Test
    public void test_isAvailable() {
        // Initialize without container