Package energy.eddie.regionconnector.cds.services

Class PollingService

java.lang.Object

energy.eddie.regionconnector.cds.services.PollingService

All Implemented Interfaces:

CommonPollingService<CdsPermissionRequest>

@Service
public class PollingService
extends Object
implements CommonPollingService<CdsPermissionRequest>

Constructor Summary

Constructors

Constructor	Description
PollingService(DataNeedCalculationService<DataNeed> calculationService, CdsServerClientFactory factory, IdentifiableDataStreams streams, CustomerDataClientErrorHandler errorHandler)

Method Summary

Modifier and Type	Method	Description
boolean	isActiveAndNeedsToBeFetched(CdsPermissionRequest permissionRequest)	Checks, if a permission request is currently active and needs to fetch data.
void	poll(CdsPermissionRequest permissionRequest)
void	pollTimeSeriesData(CdsPermissionRequest pr)	Polls future meter readings for active permission requests.
reactor.core.publisher.Mono<reactor.util.function.Tuple5<List<energy.eddie.regionconnector.cds.openapi.model.AccountsEndpoint200ResponseAllOfAccountsInner>,List<energy.eddie.regionconnector.cds.openapi.model.ServiceContractEndpoint200ResponseAllOfServiceContractsInner>,List<energy.eddie.regionconnector.cds.openapi.model.ServicePointEndpoint200ResponseAllOfServicePointsInner>,List<energy.eddie.regionconnector.cds.openapi.model.MeterDeviceEndpoint200ResponseAllOfMeterDevicesInner>,List<energy.eddie.regionconnector.cds.openapi.model.UsageSegmentEndpoint200ResponseAllOfUsageSegmentsInner>>>	pollTimeSeriesData(CdsPermissionRequest pr, ZonedDateTime start, ZonedDateTime end)

Methods inherited from class java.lang.Object

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

Constructor Details

PollingService

public PollingService(DataNeedCalculationService<DataNeed> calculationService,
 CdsServerClientFactory factory,
 IdentifiableDataStreams streams,
 CustomerDataClientErrorHandler errorHandler)

Method Details

poll

public void poll(CdsPermissionRequest permissionRequest)

pollTimeSeriesData

public void pollTimeSeriesData(CdsPermissionRequest pr)

Description copied from interface: CommonPollingService

Polls future meter readings for active permission requests.

Specified by:

pollTimeSeriesData in interface CommonPollingService<CdsPermissionRequest>

Parameters:

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

isActiveAndNeedsToBeFetched

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

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<reactor.util.function.Tuple5<List<energy.eddie.regionconnector.cds.openapi.model.AccountsEndpoint200ResponseAllOfAccountsInner>,List<energy.eddie.regionconnector.cds.openapi.model.ServiceContractEndpoint200ResponseAllOfServiceContractsInner>,List<energy.eddie.regionconnector.cds.openapi.model.ServicePointEndpoint200ResponseAllOfServicePointsInner>,List<energy.eddie.regionconnector.cds.openapi.model.MeterDeviceEndpoint200ResponseAllOfMeterDevicesInner>,List<energy.eddie.regionconnector.cds.openapi.model.UsageSegmentEndpoint200ResponseAllOfUsageSegmentsInner>>> pollTimeSeriesData(CdsPermissionRequest pr,
 ZonedDateTime start,
 ZonedDateTime end)