Package com.persequor.saga.modules.ffmreader.service

Class AbstractFileBaseFlightService<DbType extends IFileBasedFlight<?>,DbFileType extends IFileBasedFile,DataType extends IFileBasedFlightData<?>,RepoType extends AbstractFlightRepository<DbType>,ParserType extends IFlighFileParser<DbType,DbFileType,DataType>>

java.lang.Object

com.persequor.saga.modules.ffmreader.service.AbstractFileBaseFlightService<DbType,DbFileType,DataType,RepoType,ParserType>

Direct Known Subclasses:

CpmFlightService, FfmFlightService

public abstract class AbstractFileBaseFlightService<DbType extends IFileBasedFlight<?>,DbFileType extends IFileBasedFile,DataType extends IFileBasedFlightData<?>,RepoType extends AbstractFlightRepository<DbType>,ParserType extends IFlighFileParser<DbType,DbFileType,DataType>>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected com.persequor.extension.acquire.IAcquireService	acquireService
protected final FlightMonitorService	flightMonitorService
protected final ParserType	parser
protected final RepoType	repository

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractFileBaseFlightService(RepoType repository, ParserType parser, FlightMonitorService flightMonitorService)

Method Summary

Modifier and Type	Method	Description
Optional<DataType>	get(String id)
Stream<DataType>	getAll()
Stream<DataType>	getDepartures(String origin, LocalDate utcDate)
abstract void	parseNewFiles()
DataType	updateFlight(DbType flight, boolean force)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

repository

protected final RepoType extends AbstractFlightRepository<DbType> repository

parser

protected final ParserType extends IFlighFileParser<DbType,DbFileType,DataType> parser

flightMonitorService

protected final FlightMonitorService flightMonitorService

acquireService

@Inject
protected com.persequor.extension.acquire.IAcquireService acquireService

Constructor Details

AbstractFileBaseFlightService

protected AbstractFileBaseFlightService(RepoType repository,
 ParserType parser,
 FlightMonitorService flightMonitorService)

Method Details

getAll

public Stream<DataType> getAll()

parseNewFiles

public abstract void parseNewFiles()

updateFlight

public DataType updateFlight(DbType flight,
 boolean force)

getDepartures

public Stream<DataType> getDepartures(String origin,
 LocalDate utcDate)

get

public Optional<DataType> get(String id)