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

Class DePermissionMarketDocumentProvider

java.lang.Object

energy.eddie.regionconnector.de.eta.providers.cim.DePermissionMarketDocumentProvider

All Implemented Interfaces:

PermissionMarketDocumentProvider, AutoCloseable

public class DePermissionMarketDocumentProvider
extends Object
implements PermissionMarketDocumentProvider

Provides CIM v0.82 Permission Market Documents for the German (DE) region connector. This class streams permission status updates 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
DePermissionMarketDocumentProvider(PermissionMarketDocumentMessageHandler<DePermissionRequest> handler)

Method Summary

Modifier and Type	Method	Description
void	close()
reactor.core.publisher.Flux<energy.eddie.cim.v0_82.pmd.PermissionEnvelope>	getPermissionMarketDocumentStream()	Data stream of all PermissionMarketDocument updates 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

DePermissionMarketDocumentProvider

public DePermissionMarketDocumentProvider(PermissionMarketDocumentMessageHandler<DePermissionRequest> handler)

Method Details

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

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception