factory.add(new TestIngester(3));
        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 {

        // Verify data is returned unchanged
        assertSame(dataMap, result);
    }

    @Test
    public void test_ingest_withFactory() {
        // Setup ingest factory
        TestIngester ingester = new TestIngester();
        ingestFactory.ingesters.add(ingester);
        ComponentUtil.register(ingestFactory, "ingestFactory");

        // Reinitialize to pick up factory
        indexUpdateCallback.init();

            return new Ingester[] { new TestIngester(throwException) };
        }

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

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

        public TestIngester(boolean throwException) {