Class FluviusBeanConfig
java.lang.Object
energy.eddie.regionconnector.be.fluvius.FluviusBeanConfig
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptioncommonFutureDataService(PollingService pollingService, BePermissionRequestRepository bePermissionRequestRepository, String cronExpr, FluviusRegionConnectorMetadata fluviusRegionConnectorMetadata, org.springframework.scheduling.TaskScheduler taskScheduler, DataNeedCalculationService<DataNeed> dataNeedCalculationService) connectionStatusMessageHandler(EventBus eventBus, BePermissionRequestRepository repository, com.fasterxml.jackson.databind.ObjectMapper jacksonObjectMapper) dataNeedCalculationService(DataNeedsService dataNeedsService, RegionConnectorMetadata metadata) eventBus()reactor.core.publisher.Flux<IdentifiableMeteringData> identifiableMeteringDataFlux(reactor.core.publisher.Sinks.Many<IdentifiableMeteringData> identifiableMeteringDataSink) reactor.core.publisher.Sinks.Many<IdentifiableMeteringData> org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizeroutbox(EventBus eventBus, BePermissionEventRepository bePermissionEventRepository) permissionMarketDocumentMessageHandler(EventBus eventBus, BePermissionRequestRepository bePermissionRequestRepository, DataNeedsService dataNeedsService, FluviusOAuthConfiguration fluviusOAuthConfiguration, CommonInformationModelConfiguration cimConfig) rawDataProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper, IdentifiableDataStreams streams) org.springframework.web.reactive.function.client.WebClientwebClient(org.springframework.web.reactive.function.client.WebClient.Builder builder, org.springframework.boot.autoconfigure.web.reactive.function.client.WebClientSsl webClientSsl, org.springframework.boot.ssl.SslBundles sslBundles, FluviusConfiguration config)
-
Constructor Details
-
FluviusBeanConfig
public FluviusBeanConfig()
-
-
Method Details
-
webClient
@Bean public org.springframework.web.reactive.function.client.WebClient webClient(org.springframework.web.reactive.function.client.WebClient.Builder builder, org.springframework.boot.autoconfigure.web.reactive.function.client.WebClientSsl webClientSsl, org.springframework.boot.ssl.SslBundles sslBundles, FluviusConfiguration config) -
dataNeedCalculationService
@Bean public DataNeedCalculationService<DataNeed> dataNeedCalculationService(DataNeedsService dataNeedsService, RegionConnectorMetadata metadata) -
eventBus
-
jsonCustomizer
@Bean public org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizer jsonCustomizer() -
rawDataProvider
@Bean public RawDataProvider rawDataProvider(com.fasterxml.jackson.databind.ObjectMapper objectMapper, IdentifiableDataStreams streams) -
identifiableMeteringDataFlux
@Bean public reactor.core.publisher.Flux<IdentifiableMeteringData> identifiableMeteringDataFlux(reactor.core.publisher.Sinks.Many<IdentifiableMeteringData> identifiableMeteringDataSink) -
identifiableMeteringDataSink
@Bean public reactor.core.publisher.Sinks.Many<IdentifiableMeteringData> identifiableMeteringDataSink() -
commonFutureDataService
@Bean public CommonFutureDataService<FluviusPermissionRequest> commonFutureDataService(PollingService pollingService, BePermissionRequestRepository bePermissionRequestRepository, @Value("${region-connector.be.fluvius.polling:0 0 17 * * *}") String cronExpr, FluviusRegionConnectorMetadata fluviusRegionConnectorMetadata, org.springframework.scheduling.TaskScheduler taskScheduler, DataNeedCalculationService<DataNeed> dataNeedCalculationService)
-