Package energy.eddie.regionconnector.simulation.providers

Class DocumentStreams

java.lang.Object

energy.eddie.regionconnector.simulation.providers.DocumentStreams

All Implemented Interfaces:

AutoCloseable

@Component
public class DocumentStreams
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
DocumentStreams(CommonInformationModelConfiguration cimConfig, tools.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<ConnectionStatusMessage>	getConnectionStatusMessageStream()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope>	getPermissionMarketDocumentStream()
reactor.core.publisher.Flux<RawDataMessage>	getRawDataMessageStream()
reactor.core.publisher.Flux<SimulatedMeterReading>	getSimulatedMeterReadingStream()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.vhd.ValidatedHistoricalDataEnvelope>	getValidatedHistoricalDataMarketDocumentsStream()
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,
 @Qualifier("jacksonJsonMapper")
 tools.jackson.databind.ObjectMapper objectMapper)

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()

close

public void close()

Specified by:

close in interface AutoCloseable

getConnectionStatusMessageStream

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

getPermissionMarketDocumentStream

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

getRawDataMessageStream

public reactor.core.publisher.Flux<RawDataMessage> getRawDataMessageStream()

getSimulatedMeterReadingStream

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