Class PollingService
java.lang.Object
energy.eddie.regionconnector.nl.mijn.aansluiting.services.PollingService
- All Implemented Interfaces:
CommonPollingService<MijnAansluitingPermissionRequest>,AutoCloseable
@Service
public class PollingService
extends Object
implements AutoCloseable, CommonPollingService<MijnAansluitingPermissionRequest>
-
Constructor Summary
ConstructorsConstructorDescriptionPollingService(Outbox outbox, OAuthManager oAuthManager, ApiClient apiClient, DataNeedsService dataNeedsService, CodeboekApiClient codeboekApiClient) -
Method Summary
Modifier and TypeMethodDescriptionvoidclose()voidfetchAccountingPointData(MijnAansluitingPermissionRequest permissionRequest) reactor.core.publisher.Flux<IdentifiableAccountingPointData> reactor.core.publisher.Flux<IdentifiableMeteredData> booleanisActiveAndNeedsToBeFetched(MijnAansluitingPermissionRequest permissionRequest) Checks, if a permission request is currently active and needs to fetch data.voidpollTimeSeriesData(MijnAansluitingPermissionRequest permissionRequest) Polls future meter readings for active permission requests.reactor.core.publisher.Mono<Map<String, ZonedDateTime>> pollTimeSeriesData(MijnAansluitingPermissionRequest permissionRequest, LocalDate start, LocalDate end)
-
Constructor Details
-
Method Details
-
fetchAccountingPointData
-
pollTimeSeriesData
Description copied from interface:CommonPollingServicePolls future meter readings for active permission requests.- Specified by:
pollTimeSeriesDatain interfaceCommonPollingService<MijnAansluitingPermissionRequest>- 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<MijnAansluitingPermissionRequest>- Parameters:
permissionRequest- The permission request whose status needs to be checked.- Returns:
- True if active and needs to be fetched, otherwise false.
-
pollTimeSeriesData
public reactor.core.publisher.Mono<Map<String,ZonedDateTime>> pollTimeSeriesData(MijnAansluitingPermissionRequest permissionRequest, LocalDate start, LocalDate end) -
identifiableMeteredDataFlux
-
identifiableAccountingPointDataFlux
public reactor.core.publisher.Flux<IdentifiableAccountingPointData> identifiableAccountingPointDataFlux() -
close
public void close()- Specified by:
closein interfaceAutoCloseable
-