Package energy.eddie.regionconnector.fi.fingrid.services

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

Constructors

Constructor	Description
PollingService(EnergyDataService energyDataService, FingridApiClient api, UpdateGranularityService updateGranularityService, DataNeedsService dataNeedsService, Outbox outbox)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<List<TimeSeriesResponse>>	forcePoll(FingridPermissionRequest permissionRequest, ZonedDateTime start, ZonedDateTime end)
boolean	isActiveAndNeedsToBeFetched(FingridPermissionRequest permissionRequest)	Checks, if a permission request is currently active and needs to fetch data.
void	pollAccountingPointData(FingridPermissionRequest permissionRequest)
void	pollTimeSeriesData(FingridPermissionRequest permissionRequest)	Polls future meter readings for active permission requests.
void	pollTimeSeriesData(FingridPermissionRequest permissionRequest, Granularity granularity)

Methods inherited from class java.lang.Object

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

Constructor Details

PollingService

public PollingService(EnergyDataService energyDataService,
 FingridApiClient api,
 UpdateGranularityService updateGranularityService,
 DataNeedsService dataNeedsService,
 Outbox outbox)

Method Details

pollTimeSeriesData

public void pollTimeSeriesData(FingridPermissionRequest permissionRequest)

Description copied from interface: CommonPollingService

Polls future meter readings for active permission requests.

Specified by:

pollTimeSeriesData in interface CommonPollingService<FingridPermissionRequest>

Parameters:

permissionRequest - The permission request that data needs to be polled for.

isActiveAndNeedsToBeFetched

public boolean isActiveAndNeedsToBeFetched(FingridPermissionRequest permissionRequest)

Description copied from interface: CommonPollingService

Checks, if a permission request is currently active and needs to fetch data.

Specified by:

isActiveAndNeedsToBeFetched in interface CommonPollingService<FingridPermissionRequest>

Parameters:

permissionRequest - The permission request whose status needs to be checked.

Returns:

True if active and needs to be fetched, otherwise false.

pollTimeSeriesData

public void pollTimeSeriesData(FingridPermissionRequest permissionRequest,
 Granularity granularity)

forcePoll

public reactor.core.publisher.Mono<List<TimeSeriesResponse>> forcePoll(FingridPermissionRequest permissionRequest,
 ZonedDateTime start,
 ZonedDateTime end)

pollAccountingPointData

public void pollAccountingPointData(FingridPermissionRequest permissionRequest)