.param("requests_per_second", requestsPerSecond)
                .param("scroll", scroll)
                .param("max_docs", maxDocs)
                .param("wait_for_completion", Boolean.toString(waitForCompletion))
                .body(source)
                .execute()) {
            if (response.getHttpStatusCode() == 200) {
                return true;
            }

            deletedIndices.add(indexName);
            return deleteIndexResult;
        }

        @Override
        public boolean reindex(final String fromIndex, final String toIndex, final boolean waitForCompletion) {
            calledMethods.add("reindex");
            reindexPairs.add(new String[] { fromIndex, toIndex });
            reindexCallCount++;

        }

        @Override
        public void start() {
            // Mock implementation
        }

        // Custom join method to avoid overriding final Thread.join()
        public void waitForCompletion(long millis) {
            // Mock implementation
        }

        @Override
        public String getOutput() {
            return output;
        }
    }