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:

EventHandler<PermissionEvent>, AutoCloseable

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

This class converts a PermissionEvent to a CIM compliant document and provides them via a Flux. 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()
reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rpmd.RequestPermissionEnvelope>	getRequestPermissionDocumentStream()

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

getRequestPermissionDocumentStream

public reactor.core.publisher.Flux<energy.eddie.cim.v1_12.rpmd.RequestPermissionEnvelope> getRequestPermissionDocumentStream()

close

public void close()

Specified by:

close in interface AutoCloseable