Package energy.eddie.regionconnector.dk.energinet.services

Class PollingService

java.lang.Object

energy.eddie.regionconnector.dk.energinet.services.PollingService

All Implemented Interfaces:

CommonPollingService<DkEnerginetPermissionRequest>

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

Field Summary

Fields

Modifier and Type	Field	Description
static final int	REQUESTED_AGGREGATION_UNAVAILABLE
static final reactor.util.retry.RetryBackoffSpec	RETRY_BACKOFF_SPEC

Constructor Summary

Constructors

Constructor	Description
PollingService(EnerginetCustomerApi energinetCustomerApi, MeterReadingPermissionUpdateAndFulfillmentService meterReadingPermissionUpdateAndFulfillmentService, Outbox outbox, com.fasterxml.jackson.databind.ObjectMapper objectMapper, DataNeedsService dataNeedsService, ApiExceptionService apiExceptionService, EnergyDataStreams energyDataStreams)

Method Summary

Modifier and Type	Method	Description
void	fetchHistoricalMeterReadings(DkEnerginetPermissionRequest permissionRequest)	This will try to fetch historical meter readings for the given permission request.
boolean	isActiveAndNeedsToBeFetched(DkEnerginetPermissionRequest permissionRequest)	Checks, if a permission request is currently active and needs to fetch data.
void	pollTimeSeriesData(DkEnerginetPermissionRequest activePermission)	Polls future meter readings for active permission requests.
reactor.core.publisher.Mono<IdentifiableApiResponse>	pollTimeSeriesData(DkEnerginetPermissionRequest permissionRequest, LocalDate from, LocalDate to)

Methods inherited from class java.lang.Object

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

Field Details

RETRY_BACKOFF_SPEC

public static final reactor.util.retry.RetryBackoffSpec RETRY_BACKOFF_SPEC

REQUESTED_AGGREGATION_UNAVAILABLE

public static final int REQUESTED_AGGREGATION_UNAVAILABLE

See Also:

• Constant Field Values

Constructor Details

PollingService

public PollingService(EnerginetCustomerApi energinetCustomerApi,
 MeterReadingPermissionUpdateAndFulfillmentService meterReadingPermissionUpdateAndFulfillmentService,
 Outbox outbox,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 DataNeedsService dataNeedsService,
 ApiExceptionService apiExceptionService,
 EnergyDataStreams energyDataStreams)

Method Details

fetchHistoricalMeterReadings

public void fetchHistoricalMeterReadings(DkEnerginetPermissionRequest permissionRequest)

This will try to fetch historical meter readings for the given permission request. If the permission request is for future data, no data will be fetched.

Parameters:

permissionRequest - for historical validated data

pollTimeSeriesData

public void pollTimeSeriesData(DkEnerginetPermissionRequest activePermission)

Description copied from interface: CommonPollingService

Polls future meter readings for active permission requests.

Specified by:

pollTimeSeriesData in interface CommonPollingService<DkEnerginetPermissionRequest>

Parameters:

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

isActiveAndNeedsToBeFetched

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

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<IdentifiableApiResponse> pollTimeSeriesData(DkEnerginetPermissionRequest permissionRequest,
 LocalDate from,
 LocalDate to)