Package energy.eddie.regionconnector.at.eda

Class AtEdaBeanConfig

java.lang.Object

energy.eddie.regionconnector.at.eda.AtEdaBeanConfig

@Configuration
@EnableConfigurationProperties({AtConfiguration.class,PontonXPAdapterConfiguration.class})
public class AtEdaBeanConfig
extends Object

Constructor Summary

Constructors

Constructor	Description
AtEdaBeanConfig()

Method Summary

Modifier and Type	Method	Description
ConnectionStatusMessageHandler<AtPermissionRequest>	connectionStatusMessageHandler(EventBus eventBus, AtPermissionRequestRepository repository, tools.jackson.databind.ObjectMapper objectMapper)
DataNeedCalculationService<DataNeed>	dataNeedCalculationService(DataNeedsService dataNeedsService, DataNeedRuleSet ruleSet)
EdaAdapter	edaAdapter(PontonMessengerConnection pontonMessengerConnection, IdentifiableConsumptionRecordService identifiableConsumptionRecordService, IdentifiableMasterDataService identifiableMasterDataService, org.springframework.scheduling.TaskScheduler taskScheduler)
EventBus	eventBus()
FulfillmentService	fulfillmentService(Outbox outbox)
org.springframework.oxm.jaxb.Jaxb2Marshaller	jaxb2Marshaller()
Outbox	outbox(EventBus eventBus, PermissionEventRepository repository)
PermissionMarketDocumentMessageHandler<AtPermissionRequest>	permissionMarketDocumentMessageHandler(EventBus eventBus, AtPermissionRequestRepository repository, DataNeedsService dataNeedsService, AtConfiguration atConfig, CommonInformationModelConfiguration cimConfig)
PontonMessengerConnection	pontonMessengerConnection(PontonXPAdapterConfiguration configuration, InboundMessageFactoryCollection inboundMessageFactoryCollection, OutboundMessageFactoryCollection outboundMessageFactoryCollection, org.springframework.web.reactive.function.client.WebClient webClient, MessengerMonitor messengerMonitor)
TransmissionScheduleProvider<PermissionRequest>	transmissionScheduleProvider()
org.springframework.web.reactive.function.client.WebClient	webClient()

Methods inherited from class java.lang.Object

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

Constructor Details

AtEdaBeanConfig

public AtEdaBeanConfig()

Method Details

edaAdapter

@Bean
public EdaAdapter edaAdapter(PontonMessengerConnection pontonMessengerConnection,
 IdentifiableConsumptionRecordService identifiableConsumptionRecordService,
 IdentifiableMasterDataService identifiableMasterDataService,
 org.springframework.scheduling.TaskScheduler taskScheduler)

pontonMessengerConnection

@Bean
@Primary
@ConditionalOnProperty(value="region-connector.at.eda.ponton.messenger.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public PontonMessengerConnection pontonMessengerConnection(PontonXPAdapterConfiguration configuration,
 InboundMessageFactoryCollection inboundMessageFactoryCollection,
 OutboundMessageFactoryCollection outboundMessageFactoryCollection,
 org.springframework.web.reactive.function.client.WebClient webClient,
 MessengerMonitor messengerMonitor)
                                                    throws de.ponton.xp.adapter.api.ConnectionException,
IOException

Throws:

de.ponton.xp.adapter.api.ConnectionException

IOException

eventBus

@Bean
public EventBus eventBus()

outbox

@Bean
public Outbox outbox(EventBus eventBus,
 PermissionEventRepository repository)

jaxb2Marshaller

@Bean
public org.springframework.oxm.jaxb.Jaxb2Marshaller jaxb2Marshaller()

fulfillmentService

@Bean
public FulfillmentService fulfillmentService(Outbox outbox)

webClient

@Bean
public org.springframework.web.reactive.function.client.WebClient webClient()

transmissionScheduleProvider

@Bean
public TransmissionScheduleProvider<PermissionRequest> transmissionScheduleProvider()

connectionStatusMessageHandler

@Bean
public ConnectionStatusMessageHandler<AtPermissionRequest> connectionStatusMessageHandler(EventBus eventBus,
 AtPermissionRequestRepository repository,
 tools.jackson.databind.ObjectMapper objectMapper)

permissionMarketDocumentMessageHandler

@Bean
public PermissionMarketDocumentMessageHandler<AtPermissionRequest> permissionMarketDocumentMessageHandler(EventBus eventBus,
 AtPermissionRequestRepository repository,
 DataNeedsService dataNeedsService,
 AtConfiguration atConfig,
 CommonInformationModelConfiguration cimConfig)

dataNeedCalculationService

@Bean
public DataNeedCalculationService<DataNeed> dataNeedCalculationService(DataNeedsService dataNeedsService,
 DataNeedRuleSet ruleSet)