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

Class DeRawDataProvider

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.DeRawDataProvider

All Implemented Interfaces:

RawDataProvider, AutoCloseable

public class DeRawDataProvider
extends Object
implements RawDataProvider

Provides raw data messages from the German (DE) MDA. This class streams raw, unprocessed data received from ETA Plus to outbound connectors. Note: This is registered as a bean via the Spring config, not as a @Component.

Constructor Summary

Constructors

Constructor	Description
DeRawDataProvider()

Method Summary

Modifier and Type	Method	Description
void	close()	Emit a complete signal on the Flow returned by RawDataProvider.getRawDataStream() in this method.
void	emitRawData(RawDataMessage message)	Emit a raw data message to all subscribers
reactor.core.publisher.Flux<RawDataMessage>	getRawDataStream()	Stream of RawDataMessages produced by this region connector.

Methods inherited from class java.lang.Object

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

Constructor Details

DeRawDataProvider

public DeRawDataProvider()

Method Details

getRawDataStream

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

Description copied from interface: RawDataProvider

Stream of RawDataMessages produced by this region connector.

Specified by:

getRawDataStream in interface RawDataProvider

Returns:

RawDataMessage stream.

close

public void close()

Description copied from interface: RawDataProvider

Emit a complete signal on the Flow returned by RawDataProvider.getRawDataStream() in this method.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RawDataProvider

emitRawData

public void emitRawData(RawDataMessage message)

Emit a raw data message to all subscribers

Parameters:

message - the raw data message to emit