Package energy.eddie.outbound.kafka.v0_91_08

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

Constructor	Description
KafkaRetransmissionConnector()

Method Summary

Modifier and Type	Method	Description
void	process(energy.eddie.cim.v0_91_08.RTREnvelope payload)
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

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

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