Package energy.eddie.outbound.rest.connectors

Class RestRetransmissionConnector

java.lang.Object

energy.eddie.outbound.rest.connectors.RestRetransmissionConnector

All Implemented Interfaces:

RetransmissionOutboundConnector, AutoCloseable

@Component
public class RestRetransmissionConnector
extends Object
implements RetransmissionOutboundConnector, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
RestRetransmissionConnector()

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Mono<RetransmissionResult>	publish(energy.eddie.cim.v0_91_08.RTREnvelope envelope)
reactor.core.publisher.Flux<RetransmissionRequest>	retransmissionRequests()	A flux of RetransmissionRequests.
void	setRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream)	Sets the stream of RetransmissionRequest to be sent to the EP app.

Methods inherited from class java.lang.Object

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

Constructor Details

RestRetransmissionConnector

public RestRetransmissionConnector()

Method Details

retransmissionRequests

public reactor.core.publisher.Flux<RetransmissionRequest> retransmissionRequests()

Description copied from interface: RetransmissionOutboundConnector

A flux of RetransmissionRequests. This is consumed by RetransmissionRequestRouter to route the retransmission requests to the correct region-connector.

Specified by:

retransmissionRequests in interface RetransmissionOutboundConnector

Returns:

Contains the regionConnectorId, the permissionRequestId and the start and end date of the timeframe that should be retransmitted.

setRetransmissionResultStream

public void setRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream)

Description copied from interface: RetransmissionOutboundConnector

Sets the stream of RetransmissionRequest to be sent to the EP app. This stream will be provided by the RetransmissionRequestRouter .

Specified by:

setRetransmissionResultStream in interface RetransmissionOutboundConnector

Parameters:

retransmissionResultStream - stream of retransmission results

publish

public reactor.core.publisher.Mono<RetransmissionResult> publish(energy.eddie.cim.v0_91_08.RTREnvelope envelope)

close

public void close()

Specified by:

close in interface AutoCloseable