};

        // 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());

     *
     * @param jobExecutor the job executor to use for execution
     * @return the execution result message or summary
     */
    public String execute(final JobExecutor jobExecutor) {
        jobExecutor(jobExecutor);
        return execute();
    }

    /**
     * Sets the job executor for this job.
     *
     * @param jobExecutor the job executor to set

    }

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

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

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

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

    // Test with jobExecutor set
    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;

    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

                + ".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);
    }

            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) {

            return null;
        }

        @Override
        public void setResponseCharacterEncoding(String encoding) {
        }
    }

    private static class TestJobExecutor extends JobExecutor {
        boolean shutdownListenerAdded = false;

        @Override
        public void addShutdownListener(ShutdownListener listener) {
            shutdownListenerAdded = true;
            listener.onShutdown();