Package energy.eddie.regionconnector.de.eta

Class DeEtaBeanConfig

java.lang.Object

energy.eddie.regionconnector.de.eta.DeEtaBeanConfig

@Configuration
@EnableConfigurationProperties(DeEtaPlusConfiguration.class)
public class DeEtaBeanConfig
extends Object

Spring configuration for the German (DE) ETA Plus region connector. This configuration class sets up beans and dependencies required by the region connector.

Constructor Summary

Constructors

Constructor	Description
DeEtaBeanConfig()

Method Summary

Modifier and Type	Method	Description
CommonFutureDataService<DePermissionRequest>	commonFutureDataService(PollingService pollingService, DePermissionRequestRepository repository, String cronExpr, org.springframework.scheduling.TaskScheduler taskScheduler, DataNeedCalculationService<DataNeed> dataNeedCalculationService)
DataNeedCalculationService<DataNeed>	dataNeedCalculationService(DataNeedsService dataNeedsService, EtaDataNeedRuleSet dataNeedRuleSet)
ConnectionStatusMessageHandler<DePermissionRequest>	deConnectionStatusMessageHandler(EventBus eventBus, DePermissionRequestRepository repository)
Outbox	deEtaOutbox(EventBus eventBus, DePermissionEventRepository eventRepository)
PermissionMarketDocumentMessageHandler<DePermissionRequest>	dePermissionMarketDocumentMessageHandler(EventBus eventBus, DePermissionRequestRepository repository, DataNeedsService dataNeedsService, DeEtaPlusConfiguration configuration, CommonInformationModelConfiguration cimConfig, TransmissionScheduleProvider<DePermissionRequest> transmissionScheduleProvider)
TransmissionScheduleProvider<DePermissionRequest>	deTransmissionScheduleProvider()
EventBus	eventBus()
JsonRawDataProvider	rawDataProvider(tools.jackson.databind.ObjectMapper objectMapper, ValidatedHistoricalDataStream vhdStream, AccountingPointDataStream apStream)

Methods inherited from class java.lang.Object

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

Constructor Details

DeEtaBeanConfig

public DeEtaBeanConfig()

Method Details

eventBus

@Bean
public EventBus eventBus()

deEtaOutbox

@Bean
public Outbox deEtaOutbox(EventBus eventBus,
 DePermissionEventRepository eventRepository)

deConnectionStatusMessageHandler

@Bean
public ConnectionStatusMessageHandler<DePermissionRequest> deConnectionStatusMessageHandler(EventBus eventBus,
 DePermissionRequestRepository repository)

dePermissionMarketDocumentMessageHandler

@Bean
public PermissionMarketDocumentMessageHandler<DePermissionRequest> dePermissionMarketDocumentMessageHandler(EventBus eventBus,
 DePermissionRequestRepository repository,
 DataNeedsService dataNeedsService,
 DeEtaPlusConfiguration configuration,
 CommonInformationModelConfiguration cimConfig,
 TransmissionScheduleProvider<DePermissionRequest> transmissionScheduleProvider)

deTransmissionScheduleProvider

@Bean
public TransmissionScheduleProvider<DePermissionRequest> deTransmissionScheduleProvider()

dataNeedCalculationService

@Bean
public DataNeedCalculationService<DataNeed> dataNeedCalculationService(DataNeedsService dataNeedsService,
 EtaDataNeedRuleSet dataNeedRuleSet)

rawDataProvider

@Bean
public JsonRawDataProvider rawDataProvider(tools.jackson.databind.ObjectMapper objectMapper,
 ValidatedHistoricalDataStream vhdStream,
 AccountingPointDataStream apStream)

commonFutureDataService

@Bean
public CommonFutureDataService<DePermissionRequest> commonFutureDataService(PollingService pollingService,
 DePermissionRequestRepository repository,
 @Value("${region-connector.de.eta.polling:0 0 17 * * *}")
 String cronExpr,
 org.springframework.scheduling.TaskScheduler taskScheduler,
 DataNeedCalculationService<DataNeed> dataNeedCalculationService)