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