Package energy.eddie.regionconnector.at.eda.provider.v0_82

Class EdaAccountingPointEnvelopeProvider

java.lang.Object

energy.eddie.regionconnector.at.eda.provider.v0_82.EdaAccountingPointEnvelopeProvider

All Implemented Interfaces:

AccountingPointEnvelopeProvider, AutoCloseable

@Component
public class EdaAccountingPointEnvelopeProvider
extends Object
implements AccountingPointEnvelopeProvider

This class is for processing incoming master data by mapping it to AccountingPointEnvelope

Constructor Summary

Constructors

Constructor	Description
EdaAccountingPointEnvelopeProvider(IdentifiableStreams streams, IntermediateAccountingPointMarketDocumentFactory factory)

Method Summary

Modifier and Type	Method	Description
void	close()	Emit a complete signal on the Flow in this method.
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope>	getAccountingPointEnvelopeFlux()	Data stream of all EddieValidatedHistoricalDataMarketDocument 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

EdaAccountingPointEnvelopeProvider

public EdaAccountingPointEnvelopeProvider(IdentifiableStreams streams,
 IntermediateAccountingPointMarketDocumentFactory factory)

Method Details

getAccountingPointEnvelopeFlux

public reactor.core.publisher.Flux<energy.eddie.cim.v0_82.ap.AccountingPointEnvelope> getAccountingPointEnvelopeFlux()

Description copied from interface: AccountingPointEnvelopeProvider

Data stream of all EddieValidatedHistoricalDataMarketDocument created by this region connector.

Specified by:

getAccountingPointEnvelopeFlux in interface AccountingPointEnvelopeProvider

Returns:

EddieValidatedHistoricalDataMarketDocument stream

close

public void close()
           throws Exception

Description copied from interface: AccountingPointEnvelopeProvider

Emit a complete signal on the Flow in this method.

Specified by:

close in interface AccountingPointEnvelopeProvider

Specified by:

close in interface AutoCloseable

Throws:

Exception