@Test public void testThatItemIsNotFiltered() throws Exception { input.delay(Delays.toMillis(59L)); Assert.assertNotNull(processor.process(input.build(false))); }
@Override public BatchExcelRow process(final BatchExcelRow item) throws Exception { if (item.getDelay() < Delays.toMillis(threshold)) { LOGGER.debug("delay<" + threshold, item); } else { LOGGER.debug("delay>=" + threshold, item); storeInContext(item); } return item; }
StoreDelayGreaterThanThresholdInContextProcessor implements ItemProcessor<BatchExcelRow, BatchExcelRow>, InitializingBean { @Override public BatchExcelRow process(final BatchExcelRow item) throws Exception { if (item.getDelay() < Delays.toMillis(threshold)) { LOGGER.debug("delay<" + threshold, item); } else { LOGGER.debug("delay>=" + threshold, item); storeInContext(item); } return item; } }
StoreDelayGreaterThanThresholdInContextProcessor implements ItemProcessor<BatchExcelRow, BatchExcelRow>, InitializingBean { @Override public BatchExcelRow process(final BatchExcelRow item) throws Exception { if (item.getDelay() < Delays.toMillis(threshold)) { LOGGER.debug("delay<" + threshold, item); } else { LOGGER.debug("delay>=" + threshold, item); storeInContext(item); } return item; }  }
StoreDelayGreaterThanThresholdInContextProcessor implements ItemProcessor<BatchExcelRow, BatchExcelRow>, InitializingBean { @Override public BatchExcelRow process(final BatchExcelRow item) throws Exception { if (item.getDelay() < Delays.toMillis(threshold)) { LOGGER.debug("delay<" + threshold, item); } else { LOGGER.debug("delay>=" + threshold, item); storeInContext(item); } return item; }  @BeforeStep void beforeStep(StepExecution stepExecution); @Override void afterPropertiesSet(); @Override BatchExcelRow process(final BatchExcelRow item); void setThreshold(Long threshold); void setKeyName(String keyName); }
StoreDelayGreaterThanThresholdInContextProcessor implements ItemProcessor<BatchExcelRow, BatchExcelRow>, InitializingBean { @Override public BatchExcelRow process(final BatchExcelRow item) throws Exception { if (item.getDelay() < Delays.toMillis(threshold)) { LOGGER.debug("delay<" + threshold, item); } else { LOGGER.debug("delay>=" + threshold, item); storeInContext(item); } return item; }  @BeforeStep void beforeStep(StepExecution stepExecution); @Override void afterPropertiesSet(); @Override BatchExcelRow process(final BatchExcelRow item); void setThreshold(Long threshold); void setKeyName(String keyName);  }