Package energy.eddie.aiida.aggregator

Class InboundAggregator

java.lang.Object

energy.eddie.aiida.aggregator.Aggregator<InboundRecord>

energy.eddie.aiida.aggregator.InboundAggregator

All Implemented Interfaces:

AutoCloseable

@Component
public class InboundAggregator
extends Aggregator<InboundRecord>

Field Summary

Fields inherited from class energy.eddie.aiida.aggregator.Aggregator

combinedRecordSink, dataSourceAdapters, healthContributorRegistry

Constructor Summary

Constructors

Constructor	Description
InboundAggregator(InboundRecordRepository inboundRecordRepository, org.springframework.boot.health.registry.HealthContributorRegistry healthContributorRegistry)

Method Summary

Modifier and Type	Method	Description
void	addNewDataSourceAdapter(DataSourceAdapter<? extends DataSource> dataSourceAdapter)	Adds a new DataSourceAdapter to this aggregator and will subscribe to the Flux returned by DataSourceAdapter.start().
reactor.core.publisher.Flux<InboundRecord>	inboundRecordFlux()
protected void	saveRecordToDatabase(InboundRecord dataRecord)

Methods inherited from class energy.eddie.aiida.aggregator.Aggregator

close, handleCombinedSinkError, handleError, publishRecordToCombinedFlux, removeDataSourceAdapter

Methods inherited from class java.lang.Object

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

Constructor Details

InboundAggregator

public InboundAggregator(InboundRecordRepository inboundRecordRepository,
 org.springframework.boot.health.registry.HealthContributorRegistry healthContributorRegistry)

Method Details

addNewDataSourceAdapter

public void addNewDataSourceAdapter(DataSourceAdapter<? extends DataSource> dataSourceAdapter)

Description copied from class: Aggregator

Adds a new DataSourceAdapter to this aggregator and will subscribe to the Flux returned by DataSourceAdapter.start().

Overrides:

addNewDataSourceAdapter in class Aggregator<InboundRecord>

Parameters:

dataSourceAdapter - The new data source adapter to add. No check is made if this is a duplicate.

saveRecordToDatabase

protected void saveRecordToDatabase(InboundRecord dataRecord)

Specified by:

saveRecordToDatabase in class Aggregator<InboundRecord>

inboundRecordFlux

public reactor.core.publisher.Flux<InboundRecord> inboundRecordFlux()