Package energy.eddie.regionconnector.nl.mijn.aansluiting.services

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

Constructors

Constructor	Description
PollingService(Outbox outbox, OAuthManager oAuthManager, ApiClient apiClient, DataNeedsService dataNeedsService, CodeboekApiClient codeboekApiClient)

Method Summary

Modifier and Type	Method	Description
void	close()
void	fetchAccountingPointData(MijnAansluitingPermissionRequest permissionRequest)
reactor.core.publisher.Flux<IdentifiableAccountingPointData>	identifiableAccountingPointDataFlux()
reactor.core.publisher.Flux<IdentifiableMeteredData>	identifiableMeteredDataFlux()
boolean	isActiveAndNeedsToBeFetched(MijnAansluitingPermissionRequest permissionRequest)	Checks, if a permission request is currently active and needs to fetch data.
void	pollTimeSeriesData(MijnAansluitingPermissionRequest permissionRequest)	Polls future meter readings for active permission requests.
reactor.core.publisher.Mono<Map<String,ZonedDateTime>>	pollTimeSeriesData(MijnAansluitingPermissionRequest permissionRequest, LocalDate start, LocalDate end)

Methods inherited from class java.lang.Object

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

Constructor Details

PollingService

public PollingService(Outbox outbox,
 OAuthManager oAuthManager,
 ApiClient apiClient,
 DataNeedsService dataNeedsService,
 CodeboekApiClient codeboekApiClient)

Method Details

fetchAccountingPointData

public void fetchAccountingPointData(MijnAansluitingPermissionRequest permissionRequest)

pollTimeSeriesData

public void pollTimeSeriesData(MijnAansluitingPermissionRequest permissionRequest)

Description copied from interface: CommonPollingService

Polls future meter readings for active permission requests.

Specified by:

pollTimeSeriesData in interface CommonPollingService<MijnAansluitingPermissionRequest>

Parameters:

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

isActiveAndNeedsToBeFetched

public boolean isActiveAndNeedsToBeFetched(MijnAansluitingPermissionRequest 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<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

public reactor.core.publisher.Flux<IdentifiableMeteredData> identifiableMeteredDataFlux()

identifiableAccountingPointDataFlux

public reactor.core.publisher.Flux<IdentifiableAccountingPointData> identifiableAccountingPointDataFlux()

close

public void close()

Specified by:

close in interface AutoCloseable