Class DatadisBeanConfig
java.lang.Object
energy.eddie.regionconnector.es.datadis.DatadisBeanConfig
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncommonFutureDataService(DataApiService apiService, EsPermissionRequestRepository repository, String cronExpr, DatadisRegionConnector connector, org.springframework.scheduling.TaskScheduler taskScheduler, DataNeedCalculationService<DataNeed> dataNeedCalculationService) connectionStatusMessageHandler(EventBus eventBus, EsPermissionRequestRepository repository) datadisConfig(String username, String password, String basePath) dataNeedCalculationService(DataNeedsService dataNeedsService) eventBus()fulfillmentService(Outbox outbox) reactor.netty.http.client.HttpClienthttpClient(DatadisApiHealthIndicator datadisApiHealthIndicator) meterReadingPermissionUpdateAndFulfillmentService(FulfillmentService fulfillmentService, Outbox outbox) com.fasterxml.jackson.databind.ObjectMapperoutbox(EventBus eventBus, EsPermissionEventRepository repository) pmdHandler(EventBus eventBus, EsPermissionRequestRepository esPermissionRequestRepository, DataNeedsService dataNeedsService, DatadisConfig config, CommonInformationModelConfiguration cimConfig) rawDataProvider(com.fasterxml.jackson.databind.ObjectMapper mapper, EnergyDataStreams streams)
-
Constructor Details
-
DatadisBeanConfig
public DatadisBeanConfig()
-
-
Method Details
-
datadisConfig
@Bean public DatadisConfig datadisConfig(@Value("${region-connector.es.datadis.username}") String username, @Value("${region-connector.es.datadis.password}") String password, @Value("${region-connector.es.datadis.basepath:https://datadis.es}") String basePath) -
objectMapper
@Bean public com.fasterxml.jackson.databind.ObjectMapper objectMapper() -
httpClient
@Bean public reactor.netty.http.client.HttpClient httpClient(DatadisApiHealthIndicator datadisApiHealthIndicator) -
eventBus
-
dataNeedCalculationService
@Bean public DataNeedCalculationService<DataNeed> dataNeedCalculationService(DataNeedsService dataNeedsService) -
rawDataProvider
@Bean public RawDataProvider rawDataProvider(com.fasterxml.jackson.databind.ObjectMapper mapper, EnergyDataStreams streams) -
commonFutureDataService
@Bean public CommonFutureDataService<EsPermissionRequest> commonFutureDataService(DataApiService apiService, EsPermissionRequestRepository repository, @Value("${region-connector.es.datadis.polling:0 0 17 * * *}") String cronExpr, DatadisRegionConnector connector, org.springframework.scheduling.TaskScheduler taskScheduler, DataNeedCalculationService<DataNeed> dataNeedCalculationService)
-