Package energy.eddie.outbound.kafka.v1_12

Class MinMaxEnvelopeKafkaConnector

java.lang.Object

energy.eddie.outbound.kafka.v1_12.MinMaxEnvelopeKafkaConnector

All Implemented Interfaces:

MinMaxEnvelopeOutboundConnector

@Component
public class MinMaxEnvelopeKafkaConnector
extends Object
implements MinMaxEnvelopeOutboundConnector

Constructor Summary

Constructors

Constructor	Description
MinMaxEnvelopeKafkaConnector()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<energy.eddie.cim.v1_12.recmmoe.RECMMOEEnvelope>	getMinMaxEnvelopes()	A flux of RECMMOEEnvelopes, which provide a min-max envelope curve for a certain time period.
void	process(energy.eddie.cim.v1_12.recmmoe.RECMMOEEnvelope payload)

Methods inherited from class java.lang.Object

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

Constructor Details

MinMaxEnvelopeKafkaConnector

public MinMaxEnvelopeKafkaConnector()

Method Details

getMinMaxEnvelopes

public reactor.core.publisher.Flux<energy.eddie.cim.v1_12.recmmoe.RECMMOEEnvelope> getMinMaxEnvelopes()

Description copied from interface: MinMaxEnvelopeOutboundConnector

A flux of RECMMOEEnvelopes, which provide a min-max envelope curve for a certain time period.

Specified by:

getMinMaxEnvelopes in interface MinMaxEnvelopeOutboundConnector

Returns:

A flux of min-max envelopes to be sent to the region-connector.

process

@KafkaListener(groupId="min-max-envelope-group",
               id="eddie-min-max-envelope-listener",
               topics="fw.${outbound-connector.kafka.eddie-id}.cim_1_12.min-max-envelope-md",
               containerFactory="minMaxEnvelopeListenerContainerFactory")
public void process(@Payload
 energy.eddie.cim.v1_12.recmmoe.RECMMOEEnvelope payload)