Package energy.eddie.aiida.adapters.datasource.fr

Class MicroTeleinfoV3Adapter

java.lang.Object

energy.eddie.aiida.adapters.datasource.DataSourceAdapter<MicroTeleinfoV3DataSource>

energy.eddie.aiida.adapters.datasource.MqttDataSourceAdapter<MicroTeleinfoV3DataSource>

energy.eddie.aiida.adapters.datasource.fr.MicroTeleinfoV3Adapter

All Implemented Interfaces:

AutoCloseable, org.eclipse.paho.mqttv5.client.MqttCallback, org.springframework.boot.actuate.health.HealthContributor, org.springframework.boot.actuate.health.HealthIndicator

public class MicroTeleinfoV3Adapter
extends MqttDataSourceAdapter<MicroTeleinfoV3DataSource>

Field Summary

Fields inherited from class energy.eddie.aiida.adapters.datasource.MqttDataSourceAdapter

asyncClient

Fields inherited from class energy.eddie.aiida.adapters.datasource.DataSourceAdapter

dataSource, healthSink, recordSink

Constructor Summary

Constructors

Constructor	Description
MicroTeleinfoV3Adapter(MicroTeleinfoV3DataSource dataSource, com.fasterxml.jackson.databind.ObjectMapper mapper, MqttConfiguration mqttConfiguration)	Creates the datasource for the Micro Teleinfo V3.

Method Summary

Modifier and Type	Method	Description
org.springframework.boot.actuate.health.Health	health()
void	messageArrived(String topic, org.eclipse.paho.mqttv5.common.MqttMessage message)	MQTT callback function that is called when a new message from the broker is received.
protected void	subscribeToHealthTopic()

Methods inherited from class energy.eddie.aiida.adapters.datasource.MqttDataSourceAdapter

authPacketArrived, close, connectComplete, createConnectOptions, deliveryComplete, disconnected, mqttErrorOccurred, setKeepAliveInterval, start

Methods inherited from class energy.eddie.aiida.adapters.datasource.DataSourceAdapter

create, dataSource, emitAiidaRecord

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.boot.actuate.health.HealthIndicator

getHealth

Constructor Details

MicroTeleinfoV3Adapter

public MicroTeleinfoV3Adapter(MicroTeleinfoV3DataSource dataSource,
 com.fasterxml.jackson.databind.ObjectMapper mapper,
 MqttConfiguration mqttConfiguration)

Creates the datasource for the Micro Teleinfo V3. It connects to the specified MQTT broker and expects that the adapter publishes its JSON messages on the specified topic. Any OBIS code without a time field will be assigned a Unix timestamp of 0.

Parameters:

dataSource - The entity of the data source.

mapper - ObjectMapper that is used to deserialize the JSON messages. A MicroTeleinfoV3DataFieldDeserializer will be registered to this mapper.

mqttConfiguration - The MQTT configuration that is used to connect to the MQTT broker.

Method Details

messageArrived

public void messageArrived(String topic,
 org.eclipse.paho.mqttv5.common.MqttMessage message)

MQTT callback function that is called when a new message from the broker is received. Will convert the message to AiidaRecords and publish them on the Flux returned by MqttDataSourceAdapter.start().

Parameters:

topic - Name of the topic, the message was published to.

message - The actual message.

health

public org.springframework.boot.actuate.health.Health health()

Specified by:

health in interface org.springframework.boot.actuate.health.HealthIndicator

Overrides:

health in class MqttDataSourceAdapter<MicroTeleinfoV3DataSource>

subscribeToHealthTopic

protected void subscribeToHealthTopic()

Overrides:

subscribeToHealthTopic in class MqttDataSourceAdapter<MicroTeleinfoV3DataSource>