// 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) {