AbstractPollableSource extends BasicSourceSemantics implements PollableSource { @Override public synchronized void configure(Context context) { super.configure(context); backoffSleepIncrement = context.getLong(PollableSourceConstants.BACKOFF_SLEEP_INCREMENT, PollableSourceConstants.DEFAULT_BACKOFF_SLEEP_INCREMENT); maxBackoffSleep = context.getLong(PollableSourceConstants.MAX_BACKOFF_SLEEP, PollableSourceConstants.DEFAULT_MAX_BACKOFF_SLEEP); } AbstractPollableSource(); Status process(); @Override synchronized void configure(Context context); long getBackOffSleepIncrement(); long getMaxBackOffSleepInterval();  }
@Test(expected = FlumeException.class) public void testExceptionStartup() throws Exception { source.configure(new Context()); }