Package energy.eddie.regionconnector.de.eta.retransmission

Class EtaRetransmissionPollingFunction

java.lang.Object

energy.eddie.regionconnector.de.eta.retransmission.EtaRetransmissionPollingFunction

All Implemented Interfaces:

PollingFunction<DePermissionRequest>

@Service
public class EtaRetransmissionPollingFunction
extends Object
implements PollingFunction<DePermissionRequest>

Polls validated historical data for retransmission requests from the ETA Plus API.

Invoked by CommonRetransmissionService only after the request has been validated (permission accepted/fulfilled, validated-historical-data need, and a window inside the permission range and in the past). The fetched data is emitted to the outbound connectors via ValidatedHistoricalDataStream.publishRetransmission(energy.eddie.regionconnector.de.eta.permission.request.DePermissionRequest, energy.eddie.regionconnector.de.eta.providers.EtaPlusMeteredData), which does not alter permission state.

Constructor Summary

Constructors

Constructor	Description
EtaRetransmissionPollingFunction(EtaPlusApiClient apiClient, ValidatedHistoricalDataStream stream, DePermissionCredentialsRepository credentialsRepository)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<RetransmissionResult>	poll(DePermissionRequest permissionRequest, RetransmissionRequest retransmissionRequest)	Used to poll data for a permission request.

Methods inherited from class java.lang.Object

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

Constructor Details

EtaRetransmissionPollingFunction

public EtaRetransmissionPollingFunction(EtaPlusApiClient apiClient,
 ValidatedHistoricalDataStream stream,
 DePermissionCredentialsRepository credentialsRepository)

Method Details

poll

public reactor.core.publisher.Mono<RetransmissionResult> poll(DePermissionRequest permissionRequest,
 RetransmissionRequest retransmissionRequest)

Description copied from interface: PollingFunction

Used to poll data for a permission request. The timeframe is specified by the retransmission request. Should only work for permission requests that are either accepted or fulfilled. The data need of the permission request has to be a ValidatedHistoricalDataDataNeed.

Specified by:

poll in interface PollingFunction<DePermissionRequest>

Parameters:

permissionRequest - The permission request for which data should be polled.

retransmissionRequest - Specifies the timeframe of the data.

Returns:

If the polling was successful.