Package energy.eddie.aiida.adapters.datasource.modbus

Class ModbusTcpDataSourceAdapter

java.lang.Object

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

energy.eddie.aiida.adapters.datasource.modbus.ModbusTcpDataSourceAdapter

All Implemented Interfaces:

AutoCloseable, org.springframework.boot.health.contributor.HealthContributor, org.springframework.boot.health.contributor.HealthIndicator

public class ModbusTcpDataSourceAdapter
extends DataSourceAdapter<ModbusDataSource>

Field Summary

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

dataSource, healthSink, healthValidationMessages, recordSink

Constructor Summary

Constructors

Constructor	Description
ModbusTcpDataSourceAdapter(ModbusDataSource dataSource)	Creates a new DataSourceAdapter with the specified data source entity.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes any open connections and frees resources used by this datasource.
org.springframework.boot.health.contributor.Health	health()
reactor.core.publisher.Flux<AiidaRecord>	start()	Starts this datasource and all records will be published on the returned Flux.

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

ModbusTcpDataSourceAdapter

public ModbusTcpDataSourceAdapter(ModbusDataSource dataSource)
                           throws IllegalArgumentException,
ModbusConnectionException

Creates a new DataSourceAdapter with the specified data source entity.

Parameters:

dataSource - The entity of the data source.

Throws:

IllegalArgumentException

ModbusConnectionException

Method Details

start

public reactor.core.publisher.Flux<AiidaRecord> start()

Description copied from class: DataSourceAdapter

Starts this datasource and all records will be published on the returned Flux.

Specified by:

start in class DataSourceAdapter<ModbusDataSource>

Returns:

Flux on which all data from this datasource will be published.

close

public void close()

Description copied from class: DataSourceAdapter

Closes any open connections and frees resources used by this datasource. Also emits a complete signal on the Flux returned by DataSourceAdapter.start().

Specified by:

close in interface AutoCloseable

Specified by:

close in class DataSourceAdapter<ModbusDataSource>

health

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

Specified by:

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

Overrides:

health in class DataSourceAdapter<ModbusDataSource>