Package energy.eddie.regionconnector.be.fluvius.service.polling

Class PollingService

java.lang.Object

energy.eddie.regionconnector.be.fluvius.service.polling.PollingService

All Implemented Interfaces:

CommonPollingService<FluviusPermissionRequest>

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
PollingService(FluviusApiClient apiClient, IdentifiableDataStreams identifiableDataStreams, Outbox outbox)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<GetEnergyResponseModelApiDataResponse>	forcePoll(FluviusPermissionRequest permissionRequest, LocalDate from, LocalDate to)
boolean	isActiveAndNeedsToBeFetched(FluviusPermissionRequest permissionRequest)	Checks, if a permission request is currently active and needs to fetch data.
void	pollTimeSeriesData(FluviusPermissionRequest permissionRequest)	Polls future meter readings for active permission requests.

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

Constructor Details

PollingService

public PollingService(FluviusApiClient apiClient,
 IdentifiableDataStreams identifiableDataStreams,
 Outbox outbox)

Method Details

forcePoll

public reactor.core.publisher.Flux<GetEnergyResponseModelApiDataResponse> forcePoll(FluviusPermissionRequest permissionRequest,
 LocalDate from,
 LocalDate to)

pollTimeSeriesData

public void pollTimeSeriesData(FluviusPermissionRequest permissionRequest)

Description copied from interface: CommonPollingService

Polls future meter readings for active permission requests.

Specified by:

pollTimeSeriesData in interface CommonPollingService<FluviusPermissionRequest>

Parameters:

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

isActiveAndNeedsToBeFetched

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

Parameters:

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

Returns:

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