@Test
    @Timeout(30000)
    public void allHeavyHangsTestWithExcessiveNumberConsumersTest() throws Exception {
        Path outputDir = getNewOutputDir("allHeavyHangsExcessiveNumberConsumers-");
        Map<String, String> args = getDefaultArgs("heavy_heavy_hangs", outputDir);
        args.put("numConsumers", "100");
        BatchProcessTestExecutor ex = new BatchProcessTestExecutor(args);
        StreamStrings streamStrings = ex.execute();
        assertEquals(7, countChildren(outputDir));

        for (int i = 0; i < 6; i++) {
            Path hvyHang = outputDir.resolve("test" + i + "_heavy_hang.xml.xml");
            assertTrue(Files.exists(hvyHang));
            assertEquals(0, Files.size(hvyHang));
        }
        assertContains("This is tika-batch's first test file", readFileToString(outputDir.resolve("test6_ok.xml.xml"), UTF_8));

        //key that the process realize that there were no more processable files
        //in the queue and does not ask for a restart!
        assertNotContained(BatchProcess.BATCH_CONSTANTS.BATCH_PROCESS_FATAL_MUST_RESTART.toString(), streamStrings.getErrString());
    }
This runs a single process.  This was useful during development,
but we don't need it because it is duplicative of {@link BatchDriverTest}
tika-batch/src/test/java/org/apache/tika/batch/fs/BatchProcessTest.java