Package energy.eddie.regionconnector.at.eda.ponton.messages

Class InboundMessageFactoryCollection

java.lang.Object

energy.eddie.regionconnector.at.eda.ponton.messages.InboundMessageFactoryCollection

@Service
public class InboundMessageFactoryCollection
extends Object

Constructor Summary

Constructors

Constructor

Description

InboundMessageFactoryCollection(List<EdaConsumptionRecordInboundMessageFactory> inboundConsumptionRecordFactories, List<EdaMasterDataInboundMessageFactory> inboundMasterDataFactories, List<EdaCMNotificationInboundMessageFactory> inboundCMNotificationFactories, List<EdaCMRevokeInboundMessageFactory> inboundCMRevokeFactories, List<EdaCPNotificationInboundMessageFactory> inboundCPNotificationFactories)

Method Summary

Modifier and Type	Method	Description
EdaCMNotificationInboundMessageFactory	activeCMNotificationFactory()
EdaCMRevokeInboundMessageFactory	activeCMRevokeFactory()
EdaConsumptionRecordInboundMessageFactory	activeConsumptionRecordFactory()
EdaCPNotificationInboundMessageFactory	activeCPNotificationFactory()
EdaMasterDataInboundMessageFactory	activeMasterDataFactory()
void	updateActiveFactories()	EDA supports multiple versions of the same schema, but they have certain validity periods.

Methods inherited from class java.lang.Object

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

Constructor Details

InboundMessageFactoryCollection

public InboundMessageFactoryCollection(List<EdaConsumptionRecordInboundMessageFactory> inboundConsumptionRecordFactories,
 List<EdaMasterDataInboundMessageFactory> inboundMasterDataFactories,
 List<EdaCMNotificationInboundMessageFactory> inboundCMNotificationFactories,
 List<EdaCMRevokeInboundMessageFactory> inboundCMRevokeFactories,
 List<EdaCPNotificationInboundMessageFactory> inboundCPNotificationFactories)

Method Details

updateActiveFactories

@Scheduled(cron="0 0 0 * * ?",
           zone="Europe/Vienna")
public void updateActiveFactories()

EDA supports multiple versions of the same schema, but they have certain validity periods. We can add support for multiple schema version of the same type, but only one of them can be active at a time. This cron job goes through all the available factories and sets the active ones based on the current date. This allows us to switch between different versions of the same message type without restarting the application.

activeMasterDataFactory

public EdaMasterDataInboundMessageFactory activeMasterDataFactory()

activeConsumptionRecordFactory

public EdaConsumptionRecordInboundMessageFactory activeConsumptionRecordFactory()

activeCMNotificationFactory

public EdaCMNotificationInboundMessageFactory activeCMNotificationFactory()

activeCMRevokeFactory

public EdaCMRevokeInboundMessageFactory activeCMRevokeFactory()

activeCPNotificationFactory

public EdaCPNotificationInboundMessageFactory activeCPNotificationFactory()