Package energy.eddie.regionconnector.at.eda

Class AtEdaBeanConfig

java.lang.Object

energy.eddie.regionconnector.at.eda.AtEdaBeanConfig

@Configuration
public class AtEdaBeanConfig
extends Object

Constructor Summary

Constructors

Constructor	Description
AtEdaBeanConfig()

Method Summary

Modifier and Type	Method	Description
AtConfiguration	atConfiguration(String eligiblePartyId)
ConnectionStatusMessageHandler<AtPermissionRequest>	connectionStatusMessageHandler(EventBus eventBus, AtPermissionRequestRepository repository, com.fasterxml.jackson.databind.ObjectMapper objectMapper)
DataNeedCalculationService<DataNeed>	dataNeedCalculationService(DataNeedsService dataNeedsService)
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()
org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizer	objectMapper()
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)
PontonXPAdapterConfiguration	pontonXPAdapterConfiguration(String adapterId, String adapterVersion, String hostname, int port, String apiEndpoint, String workFolder, String username, String password)
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

pontonXPAdapterConfiguration

@Bean
@Scope("singleton")
public PontonXPAdapterConfiguration pontonXPAdapterConfiguration(@Value("${region-connector.at.eda.ponton.messenger.adapter.id}")
 String adapterId,
 @Value("${region-connector.at.eda.ponton.messenger.adapter.version}")
 String adapterVersion,
 @Value("${region-connector.at.eda.ponton.messenger.hostname}")
 String hostname,
 @Value("${region-connector.at.eda.ponton.messenger.port}")
 int port,
 @Value("${region-connector.at.eda.ponton.messenger.api.endpoint}")
 String apiEndpoint,
 @Value("${region-connector.at.eda.ponton.messenger.folder}")
 String workFolder,
 @Value("${region-connector.at.eda.ponton.messenger.username}")
 String username,
 @Value("${region-connector.at.eda.ponton.messenger.password}")
 String password)

atConfiguration

@Bean
public AtConfiguration atConfiguration(@Value("${region-connector.at.eda.eligibleparty.id}")
 String eligiblePartyId)

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,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper)

objectMapper

@Bean
public org.springframework.boot.autoconfigure.jackson.Jackson2ObjectMapperBuilderCustomizer 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)