private final CountDownLatch listenerLatch = new CountDownLatch(1);

  private volatile boolean throwException = false;

  private final ListenableFutureTask<Integer> task =
      ListenableFutureTask.create(
          () -> {
            runLatch.countDown();
            taskLatch.await();
            if (throwException) {
              throw new IllegalStateException("Fail");
            }
            return 25;

        private boolean throwExceptionOnConvert = false;

        public void setThrowExceptionOnInit(boolean throwException) {
            this.throwExceptionOnInit = throwException;
        }

        public void setThrowExceptionOnConvert(boolean throwException) {
            this.throwExceptionOnConvert = throwException;
        }

        @Override
        public void init() throws IOException {

        private boolean throwException = false;

        @Override
        public Ingester[] getIngesters() {
            return new Ingester[] { new TestIngester(throwException) };
        }

        public void setThrowException(boolean throwException) {
            this.throwException = throwException;
        }
    }

        }

        public void setPurgeCallCount(long count) {
            this.purgeCallCount = count;
        }

        public void setThrowException(boolean throwException) {
            this.throwException = throwException;
        }

        public void setExceptionMessage(String message) {
            this.exceptionMessage = message;
        }

        public long getPurgeExpiry() {

  private final CountDownLatch listenerLatch = new CountDownLatch(1);

  private volatile boolean throwException = false;

  private final ListenableFutureTask<Integer> task =
      ListenableFutureTask.create(
          () -> {
            runLatch.countDown();
            taskLatch.await();
            if (throwException) {
              throw new IllegalStateException("Fail");
            }
            return 25;

        queryRescorer = new QueryRescorer() {
            @Override
            public RescorerBuilder<?> evaluate(Map<String, Object> params) {
                if (params != null && params.containsKey("throwException")) {
                    throw new RuntimeException("Test exception");
                }
                return createMockRescorerBuilder();
            }
        };

        // Test normal case

        }

        public void setExecuteResult(String executeResult) {
            this.executeResult = executeResult;
        }

        public void setThrowException(boolean throwException) {
            this.throwException = throwException;
        }

        // Expose protected methods for testing
        public void testAddSystemProperty(List<String> cmdList, String name, String defaultValue, String appendValue) {

        int exitValue = 0;
        String processOutput = "Test output";
        RuntimeException throwException = null;

        @Override
        public JobProcess startProcess(String sessionId, List<String> cmdList, java.util.function.Consumer<ProcessBuilder> pbConsumer) {
            if (throwException != null) {
                throw throwException;
            }

            startProcessCalled = true;

        int exitValue = 0;
        String processOutput = "Test output";
        RuntimeException throwException = null;

        @Override
        public JobProcess startProcess(String sessionId, List<String> cmdList, java.util.function.Consumer<ProcessBuilder> pbConsumer) {
            if (throwException != null) {
                throw throwException;
            }

            startProcessCalled = true;

            }
        };
    }

    private FessAdminAction createGodHandAction(final ActivityHelper spyActivityHelper, final OptionalThing<FessUserBean> userBean,
            final boolean throwException) {
        return new FessAdminAction() {
            {
                activityHelper = spyActivityHelper;
            }

            @Override
            protected String getActionRole() {