Class PollingService
java.lang.Object
energy.eddie.regionconnector.fi.fingrid.services.PollingService
- All Implemented Interfaces:
CommonPollingService<FingridPermissionRequest>
@Service
public class PollingService
extends Object
implements CommonPollingService<FingridPermissionRequest>
-
Constructor Summary
ConstructorsConstructorDescriptionPollingService(EnergyDataService energyDataService, FingridApiClient api, UpdateGranularityService updateGranularityService, DataNeedsService dataNeedsService, Outbox outbox) -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Mono<List<TimeSeriesResponse>> forcePoll(FingridPermissionRequest permissionRequest, ZonedDateTime start, ZonedDateTime end) booleanisActiveAndNeedsToBeFetched(FingridPermissionRequest permissionRequest) Checks, if a permission request is currently active and needs to fetch data.voidpollAccountingPointData(FingridPermissionRequest permissionRequest) voidpollTimeSeriesData(FingridPermissionRequest permissionRequest) Polls future meter readings for active permission requests.voidpollTimeSeriesData(FingridPermissionRequest permissionRequest, Granularity granularity)
-
Constructor Details
-
Method Details
-
pollTimeSeriesData
Description copied from interface:CommonPollingServicePolls future meter readings for active permission requests.- Specified by:
pollTimeSeriesDatain interfaceCommonPollingService<FingridPermissionRequest>- Parameters:
permissionRequest- The permission request that data needs to be polled for.
-
isActiveAndNeedsToBeFetched
Description copied from interface:CommonPollingServiceChecks, if a permission request is currently active and needs to fetch data.- Specified by:
isActiveAndNeedsToBeFetchedin interfaceCommonPollingService<FingridPermissionRequest>- Parameters:
permissionRequest- The permission request whose status needs to be checked.- Returns:
- True if active and needs to be fetched, otherwise false.
-
pollTimeSeriesData
-
forcePoll
public reactor.core.publisher.Mono<List<TimeSeriesResponse>> forcePoll(FingridPermissionRequest permissionRequest, ZonedDateTime start, ZonedDateTime end) -
pollAccountingPointData
-