Package energy.eddie.regionconnector.shared.event.sourcing.handlers.integration

Class PermissionMarketDocumentMessageHandler<T extends PermissionRequest>

java.lang.Object

energy.eddie.regionconnector.shared.event.sourcing.handlers.integration.PermissionMarketDocumentMessageHandler<T>

All Implemented Interfaces:

PermissionMarketDocumentProvider, EventHandler<PermissionEvent>, AutoCloseable

public class PermissionMarketDocumentMessageHandler<T extends PermissionRequest>
extends Object
implements EventHandler<PermissionEvent>, PermissionMarketDocumentProvider

An implementation for the PermissionMarketDocumentProvider that converts a PermissionEvent to a CIM compliant document. It subscribes to all events present in an EventBus and based on thos creates PermissionMarketDocuments.

Constructor Summary

Constructors

Constructor	Description
PermissionMarketDocumentMessageHandler(EventBus eventBus, PermissionRequestRepository<T> repository, DataNeedsService dataNeedsService, String eligiblePartyId, CommonInformationModelConfiguration cimConfig, TransmissionScheduleProvider<T> transmissionScheduleProvider, ZoneId zoneId)

Method Summary

Modifier and Type	Method	Description
void	accept(PermissionEvent permissionEvent)	Subscription method for the event bus
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

PermissionMarketDocumentMessageHandler

public PermissionMarketDocumentMessageHandler(EventBus eventBus,
 PermissionRequestRepository<T> repository,
 DataNeedsService dataNeedsService,
 String eligiblePartyId,
 CommonInformationModelConfiguration cimConfig,
 TransmissionScheduleProvider<T> transmissionScheduleProvider,
 ZoneId zoneId)

Method Details

accept

public void accept(PermissionEvent permissionEvent)

Description copied from interface: EventHandler

Subscription method for the event bus

Specified by:

accept in interface EventHandler<T extends PermissionRequest>

Parameters:

permissionEvent - event that indicates that a permission request has been changed

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

Specified by:

close in interface AutoCloseable