Package energy.eddie.regionconnector.shared.retransmission

Class CommonRetransmissionService<T extends PermissionRequest>

java.lang.Object

energy.eddie.regionconnector.shared.retransmission.CommonRetransmissionService<T>

Type Parameters:

T - The type of permission request

All Implemented Interfaces:

RegionConnectorRetransmissionService

public class CommonRetransmissionService<T extends PermissionRequest>
extends Object
implements RegionConnectorRetransmissionService

A service that is used to request validated historical data for retransmission requests

Constructor Summary

Constructors

Constructor	Description
CommonRetransmissionService(PermissionRequestRepository<T> repository, PollingFunction<T> pollingFunction, RetransmissionValidation validation)	Creates the CommonRetransmissionService.

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Mono<RetransmissionResult>	requestRetransmission(RetransmissionRequest retransmissionRequest)	Validates the retransmission request and the requests the validated historical data if the validation was successful.

Methods inherited from class java.lang.Object

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

Constructor Details

CommonRetransmissionService

public CommonRetransmissionService(PermissionRequestRepository<T> repository,
 PollingFunction<T> pollingFunction,
 RetransmissionValidation validation)

Creates the CommonRetransmissionService.

Parameters:

repository - Is used to request the permission request associated with the retransmission request

pollingFunction - Used to poll the validated historical data

validation - Validates the retransmission request

Method Details

requestRetransmission

public reactor.core.publisher.Mono<RetransmissionResult> requestRetransmission(RetransmissionRequest retransmissionRequest)

Validates the retransmission request and the requests the validated historical data if the validation was successful.

Specified by:

requestRetransmission in interface RegionConnectorRetransmissionService

Parameters:

retransmissionRequest - the request specifying the data to be retransmitted

Returns:

the result of the retransmission request