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 -
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_12.ack.AcknowledgementEnvelope> org.springframework.security.crypto.bcrypt.BCryptPasswordEncoderbCryptPasswordEncoder(AiidaConfiguration configuration) org.eclipse.paho.mqttv5.client.MqttConnectionOptionsconnectionOptions(AiidaConfiguration configuration) connectionStatusMessageHandler(EventBus eventBus, AiidaPermissionRequestViewRepository repository) dataNeedCalculationService(DataNeedsService dataNeedsService, DataNeedRuleSet ruleSet) eventBus()org.eclipse.paho.mqttv5.client.MqttAsyncClientmqttClient(org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions, org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler scheduler, MqttEventPublisher eventPublisher, AiidaConfiguration configuration) Creates a newMqttAsyncClientand initiates the connection toAiidaConfiguration.mqttServerUri().mqttMessageCallback(AiidaMessageProcessorRegistry messageProcessorRegistry) reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_04.rtd.RTDEnvelope> reactor.core.publisher.Sinks.Many<energy.eddie.cim.v1_12.rtd.RTDEnvelope> org.springframework.boot.jackson.autoconfigure.JsonMapperBuilderCustomizeroutbox(EventBus eventBus, AiidaPermissionEventRepository repository) permissionMarketDocumentMessageHandler(EventBus eventBus, AiidaPermissionRequestViewRepository repository, AiidaConfiguration configuration, CommonInformationModelConfiguration cimConfig, TransmissionScheduleProvider<AiidaPermissionRequest> transmissionScheduleProvider, DataNeedsService dataNeedsService) reactor.core.publisher.Sinks.Many<RawDataMessage> reactor.core.publisher.Sinks.Many<AiidaConnectionStatusMessageDto> transmissionScheduleProvider(DataNeedsService dataNeedsService)
-
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
-
statusSink
-
transmissionScheduleProvider
@Bean public TransmissionScheduleProvider<AiidaPermissionRequest> transmissionScheduleProvider(DataNeedsService dataNeedsService) -
eventBus
-
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 newMqttAsyncClientand initiates the connection toAiidaConfiguration.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)
-