Package energy.eddie.aiida.adapters.datasource.at

Class OesterreichsEnergieAdapter

java.lang.Object

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

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

energy.eddie.aiida.adapters.datasource.at.OesterreichsEnergieAdapter

All Implemented Interfaces:

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

public class OesterreichsEnergieAdapter
extends MqttDataSourceAdapter<OesterreichsEnergieDataSource>

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
OesterreichsEnergieAdapter(OesterreichsEnergieDataSource dataSource, com.fasterxml.jackson.databind.ObjectMapper mapper, MqttConfiguration mqttConfiguration)	Creates the datasource for the Oesterreichs Energie adapter.

Method Summary

Modifier and Type	Method	Description
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, health, 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

OesterreichsEnergieAdapter

public OesterreichsEnergieAdapter(OesterreichsEnergieDataSource dataSource,
 com.fasterxml.jackson.databind.ObjectMapper mapper,
 MqttConfiguration mqttConfiguration)

Creates the datasource for the Oesterreichs Energie adapter. 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 OesterreichsEnergieAdapterValueDeserializer 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.