factory.add(new TestIngester(2));
        factory.add(new TestIngester(1));
        Ingester[] ingesters = factory.getIngesters();
        assertEquals(1, ingesters[0].getPriority());
        assertEquals(2, ingesters[1].getPriority());
        assertEquals(3, ingesters[2].getPriority());
    }

    private static class TestIngester extends Ingester {
        public TestIngester(int priority) {
            this.priority = priority;

    }

    private static class TestIngestFactory extends IngestFactory {
        List<Ingester> ingesters = new ArrayList<>();

        @Override
        public Ingester[] getIngesters() {
            return ingesters.toArray(new Ingester[0]);
        }
    }

    private static class TestIngester extends Ingester {
        int processCalled = 0;

        @Override

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

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

    private static class TestIngester extends Ingester {
        private final boolean throwException;