Package energy.eddie.outbound.rest.connectors.cim.v1_12

Class CimConnector

java.lang.Object

energy.eddie.outbound.rest.connectors.cim.v1_12.CimConnector

All Implemented Interfaces:

MinMaxEnvelopeOutboundConnector, AutoCloseable

@Component("cimConnectorV1_12")
public class CimConnector
extends Object
implements MinMaxEnvelopeOutboundConnector, AutoCloseable

Constructor Summary

Constructors

Constructor	Description
CimConnector()

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope>	getAcknowledgementMarketDocumentStream()
reactor.core.publisher.Flux<energy.eddie.cim.v1_12.esr.ESRDMDEnvelope>	getEnergySharingReferenceDataMarketDocumentStream()
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.
reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rtd.RTDEnvelope>	getNearRealTimeDataMarketDocumentStream()
void	publish(energy.eddie.cim.v1_12.recmmoe.RECMMOEEnvelope minMaxEnvelope)
void	setAcknowledgementMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> marketDocumentStream)
void	setEnergySharingReferenceDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.esr.ESRDMDEnvelope> marketDocumentStream)
void	setNearRealTimeDataMarketDocumentStreamV1_12(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rtd.RTDEnvelope> marketDocumentStream)

Methods inherited from class java.lang.Object

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

Constructor Details

CimConnector

public CimConnector()

Method Details

getNearRealTimeDataMarketDocumentStream

public reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rtd.RTDEnvelope> getNearRealTimeDataMarketDocumentStream()

setNearRealTimeDataMarketDocumentStreamV1_12

public void setNearRealTimeDataMarketDocumentStreamV1_12(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rtd.RTDEnvelope> marketDocumentStream)

getAcknowledgementMarketDocumentStream

public reactor.core.publisher.Flux<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> getAcknowledgementMarketDocumentStream()

setAcknowledgementMarketDocumentStream

public void setAcknowledgementMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> marketDocumentStream)

getEnergySharingReferenceDataMarketDocumentStream

public reactor.core.publisher.Flux<energy.eddie.cim.v1_12.esr.ESRDMDEnvelope> getEnergySharingReferenceDataMarketDocumentStream()

setEnergySharingReferenceDataMarketDocumentStream

public void setEnergySharingReferenceDataMarketDocumentStream(reactor.core.publisher.Flux<energy.eddie.cim.v1_12.esr.ESRDMDEnvelope> marketDocumentStream)

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.

publish

public void publish(energy.eddie.cim.v1_12.recmmoe.RECMMOEEnvelope minMaxEnvelope)

close

public void close()

Specified by:

close in interface AutoCloseable