Class KafkaRetransmissionConnector
java.lang.Object
energy.eddie.outbound.kafka.v0_91_08.KafkaRetransmissionConnector
- All Implemented Interfaces:
RetransmissionOutboundConnector
@Component
public class KafkaRetransmissionConnector
extends Object
implements RetransmissionOutboundConnector
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidprocess(energy.eddie.cim.v0_91_08.RTREnvelope payload) reactor.core.publisher.Flux<RetransmissionRequest> A flux ofRetransmissionRequests.voidsetRetransmissionResultStream(reactor.core.publisher.Flux<RetransmissionResult> retransmissionResultStream) Sets the stream ofRetransmissionRequestto be sent to the EP app.
-
Constructor Details
-
KafkaRetransmissionConnector
public KafkaRetransmissionConnector()
-
-
Method Details
-
process
@KafkaListener(groupId="retransmission-group", id="eddie-retransmission-listener", topics="fw.${outbound-connector.kafka.eddie-id}.cim_0_91_08.redistribution-transaction-rd", containerFactory="rtrEnvelopeListenerContainerFactory") public void process(@Payload energy.eddie.cim.v0_91_08.RTREnvelope payload) -
retransmissionRequests
Description copied from interface:RetransmissionOutboundConnectorA flux ofRetransmissionRequests. This is consumed byRetransmissionRequestRouterto route the retransmission requests to the correct region-connector.- Specified by:
retransmissionRequestsin interfaceRetransmissionOutboundConnector- 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:RetransmissionOutboundConnectorSets the stream ofRetransmissionRequestto be sent to the EP app. This stream will be provided by theRetransmissionRequestRouter.- Specified by:
setRetransmissionResultStreamin interfaceRetransmissionOutboundConnector- Parameters:
retransmissionResultStream- stream of retransmission results
-