Logger.getLogger(this.getClass().getName()).log(Level.INFO, "Using " + threadPoolSize + " threads");
}
@Override
protected void processAction(FlowSourceSet sourcesSet, final List<FlowDataProcessingRule> rules) throws FlowProcessingException{
final FlowRecordIterator iterator;
try {
iterator = sourcesSet.getRecordIterator(pool);
} catch (FlowSourceException ex) {
throw new FlowProcessingException(ex);
}