};

        // Add first listener
        jobExecutor.addShutdownListener(listener1);
        assertEquals(listener1, jobExecutor.shutdownListener);

        // Replace with second listener
        jobExecutor.addShutdownListener(listener2);
        assertEquals(listener2, jobExecutor.shutdownListener);

        // Verify only second listener is called
        jobExecutor.shutdown();
        assertEquals(10, callCount.get());

    }

    // Test getExecuteType
    @Test
    public void test_getExecuteType() {
        assertEquals("test", execJob.getExecuteType());

        execJob.setExecuteType("crawler");
        assertEquals("crawler", execJob.getExecuteType());
    }

    // Test jobExecutor setter
    @Test
    public void test_jobExecutor() {
        JobExecutor jobExecutor = new JobExecutor() {

        }
        final String scriptType = scheduledJob.getScriptType();
        final String script = scheduledJob.getScriptData();

        final JobExecutor jobExecutor = ComponentUtil.getJobExecutor(scriptType);
        if (jobExecutor == null) {
            throw new ScheduledJobException("No jobExecutor: " + scriptType);
        }

        if (!jobManager.findJobByUniqueOf(LaJobUnique.of(id)).isPresent()) {

        ComponentUtil.register(jobHelper, "jobHelper");

        // JobExecutor that returns a simple result
        final JobExecutor jobExecutor = new JobExecutor() {
            @Override
            public Object execute(final String scriptType, final String script) {
                return "OK";
            }
        };
        ComponentUtil.register(jobExecutor, "scriptJobExecutor");
    }

    /**

                + ".webConfigIds([\"%s\"] as String[])" + ".jobExecutor(executor).execute();", webCofigId, webCofigId);
    }

    protected static String buildFileConfigJobScript(final String fileConfigId) {
        return String.format("return container.getComponent(\"crawlJob\")" + ".logLevel(\"info\")" + ".sessionId(\"%s\")"
                + ".fileConfigIds([\"%s\"] as String[])" + ".jobExecutor(executor).execute();", fileConfigId, fileConfigId);
    }

    public void test_execute_withJobExecutor() {
        pythonJob.filename("test.py");

        TestJobExecutor jobExecutor = new TestJobExecutor();
        pythonJob.jobExecutor = jobExecutor;

        testProcessHelper.exitValue = 0;

        pythonJob.execute();

        assertTrue(jobExecutor.shutdownListenerAdded);
    }

    // Test environment variables setup
    @Test

        assertNotNull(result);
        assertTrue(result.contains("Session Id:"));
    }

    // Test with jobExecutor set
    @Test
    public void test_execute_withJobExecutor() {
        final List<JobExecutor.ShutdownListener> shutdownListeners = new ArrayList<>();

        JobExecutor mockJobExecutor = new JobExecutor() {
            @Override
            public void addShutdownListener(ShutdownListener listener) {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.job.impl;

import java.util.Map;

import org.codelibs.fess.exception.ScriptEngineException;
import org.codelibs.fess.job.JobExecutor;
import org.codelibs.fess.script.ScriptEngine;
import org.codelibs.fess.script.ScriptEngineFactory;
import org.codelibs.fess.unit.UnitFessTestCase;
import org.codelibs.fess.util.ComponentUtil;

            cacheCleared = true;
        }

        public boolean isCacheCleared() {
            return cacheCleared;
        }
    }

    // Mock JobExecutor implementation
    private class MockJobExecutor extends JobExecutor {
        private boolean hasShutdownListener = false;

        @Override
        public void addShutdownListener(ShutdownListener listener) {

import org.codelibs.fess.helper.ViewHelper;
import org.codelibs.fess.helper.VirtualHostHelper;
import org.codelibs.fess.indexer.IndexUpdater;
import org.codelibs.fess.ingest.IngestFactory;
import org.codelibs.fess.job.JobExecutor;
import org.codelibs.fess.ldap.LdapManager;
import org.codelibs.fess.mylasta.direction.FessConfig;
import org.codelibs.fess.mylasta.direction.FessProp;
import org.codelibs.fess.opensearch.client.SearchEngineClient;