// Test success message constants
        assertEquals("{success.update_crawler_params}", FessMessages.SUCCESS_update_crawler_params);
        assertEquals("{success.delete_doc_from_index}", FessMessages.SUCCESS_delete_doc_from_index);
        assertEquals("{success.crawling_info_delete_all}", FessMessages.SUCCESS_crawling_info_delete_all);

        };
        ComponentUtil.register(mockSearchLogHelper, "searchLogHelper");

        // Execute the job
        String result = aggregateLogJob.execute();

        // Verify result is empty string on success
        assertNotNull(result);
        assertEquals("", result);
    }

    public void test_execute_withException() {
        // Setup mock SearchLogHelper that throws exception

          TimeoutsToUse.ANY,
          Outcome.SUCCESS);
      addTests(
          suite,
          method,
          Scenario.UNSATISFIED_AND_UNOCCUPIED_BEFORE_ENTERING,
          TimeoutsToUse.FINITE,
          isGuarded(method)
              ? (isBoolean(method) ? Outcome.FAILURE : Outcome.HANG)
              : Outcome.SUCCESS);
      addTests(
          suite,
          method,

        });
        refresh();
    }

    /**
     * Indexes suggest data from documents.
     *
     * @param success A callback for successful indexing.
     * @param error   A callback for indexing errors.
     */
    public void indexFromDocuments(final Consumer<Boolean> success, final Consumer<Throwable> error) {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

        throw new UnsupportedOperationException();
    }

    /**
     * Starts a scheduled job by ID.
     *
     * @param id the ID of the scheduled job to start
     * @return JSON response indicating success or failure
     */
    // PUT /api/admin/scheduler/{id}/start
    @Execute(urlPattern = "{}/@word")
    public JsonResponse<ApiResult> put$start(final String id) {

        createRequiredDirectories();
        String existingSessionId = "EXISTING123456";
        suggestJob.sessionId(existingSessionId);

        mockProcessHelper.setExitValue(0);
        mockProcessHelper.setOutput("Success");

        String result = suggestJob.execute();

        assertTrue(result.contains("Session Id: " + existingSessionId));
        assertEquals(existingSessionId, suggestJob.sessionId);
    }

    fun executeOn(executorService: ExecutorService) {
      client.dispatcher.assertLockNotHeld()

      var success = false
      try {
        executorService.execute(this)
        success = true
      } catch (e: RejectedExecutionException) {
        failRejected(e)
      } finally {
        if (!success) {
          client.dispatcher.finished(this) // This call is no longer running!
        }
      }
    }

    }

    /**
     * Deletes a user setting by ID.
     *
     * @param id the ID of the user setting to delete
     * @return JSON response indicating success or failure
     */
    // DELETE /api/admin/user/setting/{id}
    @Execute
    public JsonResponse<ApiResult> delete$setting(final String id) {
        final User entity = userService.getUser(id).orElseGet(() -> {

    private JobHelper originalJobHelper;

    // Concrete implementation for testing
    private static class TestExecJob extends ExecJob {
        private String executeType = "test";
        private String executeResult = "success";
        private boolean throwException = false;

        @Override
        public String execute() {
            if (throwException) {
                throw new RuntimeException("Test exception");
            }

    }

    /**
     * Deletes a request header setting by ID.
     *
     * @param id the ID of the request header setting to delete
     * @return JSON response indicating success or failure
     */
    // DELETE /api/admin/reqheader/setting/{id}
    @Execute
    public JsonResponse<ApiResult> delete$setting(final String id) {
        reqHeaderService.getRequestHeader(id).ifPresent(entity -> {