Package energy.eddie.regionconnector.de.eta.providers.cim.v104

Class DeValidatedHistoricalDataMarketDocumentProvider

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.cim.v104.DeValidatedHistoricalDataMarketDocumentProvider

All Implemented Interfaces:

ValidatedHistoricalDataMarketDocumentProvider

public class DeValidatedHistoricalDataMarketDocumentProvider
extends Object
implements ValidatedHistoricalDataMarketDocumentProvider

Provides CIM v1.04 Validated Historical Data Market Documents for the German (DE) region connector. This class streams validated historical metering data in CIM format to outbound connectors. Note: This is registered as a bean via the Spring config, not as a @Component.

Constructor Summary

Constructors

Constructor	Description
DeValidatedHistoricalDataMarketDocumentProvider()

Method Summary

Modifier and Type	Method	Description
void	emitDocument(energy.eddie.cim.v1_04.vhd.VHDEnvelope document)	Emit a validated historical data market document to all subscribers
reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope>	getValidatedHistoricalDataMarketDocumentsStream()	Data stream of all VHDEnvelope created by this region connector.

Methods inherited from class java.lang.Object

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

Constructor Details

DeValidatedHistoricalDataMarketDocumentProvider

public DeValidatedHistoricalDataMarketDocumentProvider()

Method Details

getValidatedHistoricalDataMarketDocumentsStream

public reactor.core.publisher.Flux<energy.eddie.cim.v1_04.vhd.VHDEnvelope> getValidatedHistoricalDataMarketDocumentsStream()

Description copied from interface: ValidatedHistoricalDataMarketDocumentProvider

Data stream of all VHDEnvelope created by this region connector.

Specified by:

getValidatedHistoricalDataMarketDocumentsStream in interface ValidatedHistoricalDataMarketDocumentProvider

Returns:

VHDEnvelope stream

emitDocument

public void emitDocument(energy.eddie.cim.v1_04.vhd.VHDEnvelope document)

Emit a validated historical data market document to all subscribers

Parameters:

document - the CIM document envelope