Package energy.eddie.regionconnector.aiida

Class AiidaBeanConfig

java.lang.Object

energy.eddie.regionconnector.aiida.AiidaBeanConfig

@Configuration
public class AiidaBeanConfig
extends Object

Constructor Summary

Constructors

Constructor	Description
AiidaBeanConfig()

Method Summary

Modifier and Type	Method	Description
AiidaConfiguration	aiidaConfiguration(String customerId, int bCryptStrength, String eddiePublicUrl, String mqttServerUri, String mqttPassword)
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)
EventBus	eventBus()
org.eclipse.paho.mqttv5.client.MqttAsyncClient	mqttClient(org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler, AiidaConfiguration configuration)	Creates a new MqttAsyncClient and initiates the connection to AiidaConfiguration.mqttServerUri().
MqttMessageCallback	mqttMessageCallback(AiidaPermissionRequestViewRepository permissionRequestViewRepository, reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink, reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataSink, reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope>	nearRealTimeDataSink()
com.fasterxml.jackson.databind.ObjectMapper	objectMapper()
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

aiidaConfiguration

@Bean
public AiidaConfiguration aiidaConfiguration(@Value("${region-connector.aiida.customer.id}")
 String customerId,
 @Value("${region-connector.aiida.bcrypt.strength}")
 int bCryptStrength,
 @Value("${eddie.public.url}")
 String eddiePublicUrl,
 @Value("${region-connector.aiida.mqtt.server.uri}")
 String mqttServerUri,
 @Value("${region-connector.aiida.mqtt.password:}")
 String mqttPassword)

objectMapper

@Bean
@Primary
public com.fasterxml.jackson.databind.ObjectMapper objectMapper()

nearRealTimeDataSink

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

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

mqttMessageCallback

@Bean
public MqttMessageCallback mqttMessageCallback(AiidaPermissionRequestViewRepository permissionRequestViewRepository,
 reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> statusSink,
 reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> nearRealTimeDataSink,
 reactor.core.publisher.Sinks.Many<RawDataMessage> rawDataMessageSink,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)