io.openems.edge.timedata.rrd4j

Class RecordWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.worker.AbstractImmediateWorker

io.openems.edge.timedata.rrd4j.RecordWorker

public class RecordWorker
extends AbstractImmediateWorker

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_NO_OF_CYCLES
protected int	noOfCycles

Fields inherited from class io.openems.common.worker.AbstractWorker

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT

Constructor Summary

Constructors

Constructor and Description
RecordWorker(Rrd4jTimedataImpl parent)

Method Summary

Modifier and Type	Method and Description
void	collectData() Collects the data from Channels.
protected void	forever() This method is called in a loop forever until the Thread gets interrupted.
void	setNoOfCycles(int noOfCycles)

Methods inherited from class io.openems.common.worker.AbstractImmediateWorker

activate, deactivate, getCycleTime

Methods inherited from class io.openems.common.worker.AbstractWorker

triggerNextRun

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_NO_OF_CYCLES

protected static final int DEFAULT_NO_OF_CYCLES

See Also:

Constant Field Values

noOfCycles

protected int noOfCycles

Constructor Detail

RecordWorker

public RecordWorker(Rrd4jTimedataImpl parent)

Method Detail

collectData

public void collectData()

Collects the data from Channels. This is called synchronously by the main OpenEMS cycle. On finish it triggers a next async task to write the data to RRD4J.

forever

protected void forever()
                throws java.lang.InterruptedException

Description copied from class: AbstractWorker

This method is called in a loop forever until the Thread gets interrupted.

Specified by:

forever in class AbstractImmediateWorker

Throws:

java.lang.InterruptedException

setNoOfCycles

public void setNoOfCycles(int noOfCycles)