Package energy.eddie.aiida.adapters.datasource.cim

Class CimAdapter

java.lang.Object

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

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

energy.eddie.aiida.adapters.datasource.cim.CimAdapter

All Implemented Interfaces:

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

public class CimAdapter
extends MqttDataSourceAdapter<CimDataSource>

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, healthValidationMessages, recordSink

Constructor Summary

Constructors

Constructor	Description
CimAdapter(CimDataSource dataSource, tools.jackson.databind.ObjectMapper mapper, MqttConfiguration mqttConfiguration)

Method Summary

Modifier and Type	Method	Description
void	messageArrived(String topic, org.eclipse.paho.mqttv5.common.MqttMessage message)

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.health.contributor.HealthIndicator

health

Constructor Details

CimAdapter

public CimAdapter(CimDataSource dataSource,
 tools.jackson.databind.ObjectMapper mapper,
 MqttConfiguration mqttConfiguration)

Method Details

messageArrived

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