@Test(expected = EventDeliveryException.class) public void testNotStarted() throws Exception { source.process(); }
public Status process() throws EventDeliveryException { Exception exception = getStartException(); if (exception != null) { throw new FlumeException("Source had error configuring or starting", exception); } if (!isStarted()) { throw new EventDeliveryException("Source is not started. It is in '" + getLifecycleState() + "' state"); } return doProcess(); }
AbstractPollableSource extends BasicSourceSemantics implements PollableSource { public Status process() throws EventDeliveryException { Exception exception = getStartException(); if (exception != null) { throw new FlumeException("Source had error configuring or starting", exception); } if (!isStarted()) { throw new EventDeliveryException("Source is not started. It is in '" + getLifecycleState() + "' state"); } return doProcess(); } }
AbstractPollableSource extends BasicSourceSemantics implements PollableSource { public Status process() throws EventDeliveryException { Exception exception = getStartException(); if (exception != null) { throw new FlumeException("Source had error configuring or starting", exception); } if (!isStarted()) { throw new EventDeliveryException("Source is not started. It is in '" + getLifecycleState() + "' state"); } return doProcess(); } AbstractPollableSource(); }
AbstractPollableSource extends BasicSourceSemantics implements PollableSource { public Status process() throws EventDeliveryException { Exception exception = getStartException(); if (exception != null) { throw new FlumeException("Source had error configuring or starting", exception); } if (!isStarted()) { throw new EventDeliveryException("Source is not started. It is in '" + getLifecycleState() + "' state"); } return doProcess(); } AbstractPollableSource(); Status process(); @Override synchronized void configure(Context context); long getBackOffSleepIncrement(); long getMaxBackOffSleepInterval(); }
AbstractPollableSource extends BasicSourceSemantics implements PollableSource { public Status process() throws EventDeliveryException { Exception exception = getStartException(); if (exception != null) { throw new FlumeException("Source had error configuring or starting", exception); } if (!isStarted()) { throw new EventDeliveryException("Source is not started. It is in '" + getLifecycleState() + "' state"); } return doProcess(); } AbstractPollableSource(); Status process(); @Override synchronized void configure(Context context); long getBackOffSleepIncrement(); long getMaxBackOffSleepInterval();  }