FilterUnscheduledTripProcessor extends AbstractGtfsDataProcessor<Trip, Trip> implements InitializingBean { @Override public Trip process(Trip item) throws Exception { Trip result = null; if (isScheduled(item.getServiceId())) { result = item; } LOGGER.debug("result", result); return result; }  @Override void afterPropertiesSet(); @Override Trip process(Trip item); void setCalendarDatesReader(ItemStreamReader<CalendarDate> calendarDatesReader); void setDate(LocalDate date);  }
@Test public void testProcess() throws Exception { expect(reader.read()).andReturn(new CalendarDate()); expect(reader.read()).andReturn(null); replayAll(); assertNull(processor.process(new Trip())); }