Package energy.eddie.regionconnector.aiida

Class AiidaBeanConfig

java.lang.Object

energy.eddie.regionconnector.aiida.AiidaBeanConfig

@Configuration
@EnableConfigurationProperties(AiidaConfiguration.class)
@Import(ObjectMapperConfig.class)
public class AiidaBeanConfig
extends Object

Constructor Summary

Constructors

Constructor	Description
AiidaBeanConfig()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope>	acknowledgementCimSink()
org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder	bCryptPasswordEncoder(AiidaConfiguration configuration)
org.eclipse.paho.mqttv5.client.MqttConnectionOptions	connectionOptions(AiidaConfiguration configuration)
ConnectionStatusMessageHandler<AiidaPermissionRequest>	connectionStatusMessageHandler(EventBus eventBus, AiidaPermissionRequestViewRepository repository)
DataNeedCalculationService<DataNeed>	dataNeedCalculationService(DataNeedsService dataNeedsService, DataNeedRuleSet ruleSet)
EventBus	eventBus()
org.eclipse.paho.mqttv5.client.MqttAsyncClient	mqttClient(org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler, MqttEventPublisher eventPublisher, AiidaConfiguration configuration)	Creates a new MqttAsyncClient and initiates the connection to AiidaConfiguration.mqttServerUri().
MqttMessageCallback	mqttMessageCallback(AiidaMessageProcessorRegistry messageProcessorRegistry)
reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope>	nearRealTimeDataCimV104Sink()
reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_12.rtd.RTDEnvelope>	nearRealTimeDataCimV112Sink()
org.springframework.boot.jackson.autoconfigure.JsonMapperBuilderCustomizer	objectMapperCustomizer()
Outbox	outbox(EventBus eventBus, AiidaPermissionEventRepository repository)
PasswordGenerator	passwordGenerator()
PermissionMarketDocumentMessageHandler<AiidaPermissionRequest>	permissionMarketDocumentMessageHandler(EventBus eventBus, AiidaPermissionRequestViewRepository repository, AiidaConfiguration configuration, CommonInformationModelConfiguration cimConfig, TransmissionScheduleProvider<AiidaPermissionRequest> transmissionScheduleProvider, DataNeedsService dataNeedsService)
reactor.core.publisher.Sinks.Many<RawDataMessage>	rawDataMessageSink()
reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto>	statusSink()
TransmissionScheduleProvider<AiidaPermissionRequest>	transmissionScheduleProvider(DataNeedsService dataNeedsService)

Methods inherited from class java.lang.Object

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

Constructor Details

AiidaBeanConfig

public AiidaBeanConfig()

Method Details

objectMapperCustomizer

@Bean
public org.springframework.boot.jackson.autoconfigure.JsonMapperBuilderCustomizer objectMapperCustomizer()

nearRealTimeDataCimV104Sink

@Bean
public reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataCimV104Sink()

nearRealTimeDataCimV112Sink

@Bean
public reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_12.rtd.RTDEnvelope> nearRealTimeDataCimV112Sink()

acknowledgementCimSink

@Bean
public reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> acknowledgementCimSink()

rawDataMessageSink

@Bean
public reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink()

statusSink

@Bean
public reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink()

transmissionScheduleProvider

@Bean
public TransmissionScheduleProvider<AiidaPermissionRequest> transmissionScheduleProvider(DataNeedsService dataNeedsService)

eventBus

@Bean
public EventBus eventBus()

outbox

@Bean
public Outbox outbox(EventBus eventBus,
 AiidaPermissionEventRepository repository)

connectionStatusMessageHandler

@Bean
public ConnectionStatusMessageHandler<AiidaPermissionRequest> connectionStatusMessageHandler(EventBus eventBus,
 AiidaPermissionRequestViewRepository repository)

permissionMarketDocumentMessageHandler

@Bean
public PermissionMarketDocumentMessageHandler<AiidaPermissionRequest> permissionMarketDocumentMessageHandler(EventBus eventBus,
 AiidaPermissionRequestViewRepository repository,
 AiidaConfiguration configuration,
 CommonInformationModelConfiguration cimConfig,
 TransmissionScheduleProvider<AiidaPermissionRequest> transmissionScheduleProvider,
 DataNeedsService dataNeedsService)

passwordGenerator

@Bean
public PasswordGenerator passwordGenerator()

bCryptPasswordEncoder

@Bean
public org.springframework.security.crypto.bcrypt.BCryptPasswordEncoder bCryptPasswordEncoder(AiidaConfiguration configuration)

connectionOptions

@Bean
public org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions(AiidaConfiguration configuration)

mqttClient

@Bean
public org.eclipse.paho.mqttv5.client.MqttAsyncClient mqttClient(org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions,
 org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler,
 MqttEventPublisher eventPublisher,
 AiidaConfiguration configuration)
                                                          throws org.eclipse.paho.mqttv5.common.MqttException

Creates a new MqttAsyncClient and initiates the connection to AiidaConfiguration.mqttServerUri().

Throws:

org.eclipse.paho.mqttv5.common.MqttException

dataNeedCalculationService

@Bean
public DataNeedCalculationService<DataNeed> dataNeedCalculationService(DataNeedsService dataNeedsService,
 DataNeedRuleSet ruleSet)

mqttMessageCallback

@Bean
public MqttMessageCallback mqttMessageCallback(AiidaMessageProcessorRegistry messageProcessorRegistry)