Package energy.eddie.api.agnostic.outbound

Interface RetransmissionOutboundConnector

All Known Implementing Classes:
AmqpInbound, KafkaRetransmissionConnector, RestRetransmissionConnector, RetransmissionAdminConsoleOutboundConnector
public interface RetransmissionOutboundConnector
A retransmission connector allows the eligible party to request retransmission of data for a specific timeframe from a region-connector.

  • Method Details

    • retransmissionRequests

      reactor.core.publisher.Flux<RetransmissionRequest> retransmissionRequests()
      A flux of RetransmissionRequests. This is consumed by RetransmissionRequestRouter to route the retransmission requests to the correct region-connector.
      Returns:
      Contains the regionConnectorId, the permissionRequestId and the start and end date of the timeframe that should be retransmitted.

    • setRetransmissionResultStream

      void setRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream)
      Sets the stream of RetransmissionRequest to be sent to the EP app. This stream will be provided by the RetransmissionRequestRouter .
      Parameters:
      retransmissionResultStream - stream of retransmission results