Package energy.eddie.regionconnector.simulation.providers

Class DocumentStreams

java.lang.Object

energy.eddie.regionconnector.simulation.providers.DocumentStreams

All Implemented Interfaces:

ConnectionStatusMessageProvider, PermissionMarketDocumentProvider, ValidatedHistoricalDataEnvelopeProvider, AutoCloseable

@Component
public class DocumentStreams
extends Object
implements ValidatedHistoricalDataEnvelopeProvider, ConnectionStatusMessageProvider, PermissionMarketDocumentProvider

Constructor Summary

Constructors

Constructor	Description
DocumentStreams(CommonInformationModelConfiguration cimConfig)

Method Summary

Modifier and Type	Method	Description
void	close()	Emit a complete signal on the Flow in this method.
reactor.core.publisher.Flux<ConnectionStatusMessage>	getConnectionStatusMessageStream()	Data stream of all connection status updates created by this region connector.
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope>	getPermissionMarketDocumentStream()	Data stream of all PermissionMarketDocument updates created by this region connector.
reactor.core.publisher.Flux<SimulatedMeterReading>	getSimulatedMeterReadingStream()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope>	getValidatedHistoricalDataMarketDocumentsStream()	Data stream of all ValidatedHistoricalDataEnvelopes created by this region connector.
void	publish(ConnectionStatusMessage connectionStatusMessage)
void	publish(energy.eddie.cim.v0_82.pmd.PermissionEnvelope permissionEnvelope)
void	publish(SimulatedMeterReading document)

Methods inherited from class java.lang.Object

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

Constructor Details

DocumentStreams

public DocumentStreams(CommonInformationModelConfiguration cimConfig)

Method Details

publish

public void publish(SimulatedMeterReading document)

publish

public void publish(ConnectionStatusMessage connectionStatusMessage)

publish

public void publish(energy.eddie.cim.v0_82.pmd.PermissionEnvelope permissionEnvelope)

getValidatedHistoricalDataMarketDocumentsStream

public reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope> getValidatedHistoricalDataMarketDocumentsStream()

Description copied from interface: ValidatedHistoricalDataEnvelopeProvider

Data stream of all ValidatedHistoricalDataEnvelopes created by this region connector.

Specified by:

getValidatedHistoricalDataMarketDocumentsStream in interface ValidatedHistoricalDataEnvelopeProvider

Returns:

ValidatedHistoricalDataEnvelope stream

close

public void close()

Description copied from interface: ValidatedHistoricalDataEnvelopeProvider

Emit a complete signal on the Flow in this method.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ConnectionStatusMessageProvider

Specified by:

close in interface ValidatedHistoricalDataEnvelopeProvider

getConnectionStatusMessageStream

public reactor.core.publisher.Flux<ConnectionStatusMessage> getConnectionStatusMessageStream()

Description copied from interface: ConnectionStatusMessageProvider

Data stream of all connection status updates created by this region connector.

Specified by:

getConnectionStatusMessageStream in interface ConnectionStatusMessageProvider

Returns:

connection status message stream

getPermissionMarketDocumentStream

public reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope> getPermissionMarketDocumentStream()

Description copied from interface: PermissionMarketDocumentProvider

Data stream of all PermissionMarketDocument updates created by this region connector. The PermissionMarketDocument will contain the new state of the permission in the process

Specified by:

getPermissionMarketDocumentStream in interface PermissionMarketDocumentProvider

Returns:

PermissionMarketDocument stream that can be consumed only once

getSimulatedMeterReadingStream

public reactor.core.publisher.Flux<SimulatedMeterReading> getSimulatedMeterReadingStream()