Package energy.eddie.aiida.adapters.datasource.shelly

Class ShellyAdapter

java.lang.Object

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

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

energy.eddie.aiida.adapters.datasource.shelly.ShellyAdapter

All Implemented Interfaces:

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

public class ShellyAdapter
extends MqttDataSourceAdapter<ShellyDataSource>

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
ShellyAdapter(ShellyDataSource dataSource, com.fasterxml.jackson.databind.ObjectMapper mapper, MqttConfiguration mqttConfiguration)	Creates the datasource for the Shelly (energy meter) devices.

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.

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

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

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

ShellyAdapter

public ShellyAdapter(ShellyDataSource dataSource,
 com.fasterxml.jackson.databind.ObjectMapper mapper,
 MqttConfiguration mqttConfiguration)

Creates the datasource for the Shelly (energy meter) devices. 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.

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<ShellyDataSource>