public static void main(final String[] args) throws IOException, InterruptedException {

        final Path proxyDir = Paths.get("/home/dev/tmp/dev/proxy");
//        final File proxyDir = new File("/tmp/stroom/dev/proxy");

        FileUtil.mkdirs(proxyDir);

        for (int i = 1; i <= 1000000000; i++) {
            final Path testFile1 = proxyDir.resolve(String.format("%08d", i) + ".zip");
            int feedNo = (i % 4) + 1;
            writeTestFile(testFile1, "TEST_FEED_" + feedNo, i + "-data1\n" + i + "-data1\n");
            Thread.sleep(200);
        }
    }
Class for creating test files in the proxy aggregation directory for manually
testing proxy aggregation
stroom-app/src/test/java/stroom/receive/ProxyAggregationLoader.java