Package io.openems.backend.timedata.timescaledb.internal.write

Class MergePointsWorker<POINT extends Point>

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.common.worker.AbstractImmediateWorker

io.openems.backend.timedata.timescaledb.internal.write.MergePointsWorker<POINT>

public class MergePointsWorker<POINT extends Point>
extends AbstractImmediateWorker

Field Summary

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

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT, thread

Constructor Summary

Constructors

Constructor	Description
MergePointsWorker(com.zaxxer.hikari.HikariDataSource dataSource, ExecutorService executor, Type type, Priority priority)

Method Summary

Modifier and Type	Method	Description
String	debugLog()	Returns a DebugLog String.
protected void	forever()	This method is called in a loop forever until the Thread gets interrupted.
BlockingQueue<POINT>	getQueue()

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

activate, deactivate, getCycleTime

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

modified, triggerNextRun

Methods inherited from class java.lang.Object

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

Constructor Details

MergePointsWorker

public MergePointsWorker(com.zaxxer.hikari.HikariDataSource dataSource,
 ExecutorService executor,
 Type type,
 Priority priority)

Method Details

getQueue

public BlockingQueue<POINT> getQueue()

forever

protected void forever()
                throws 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:

InterruptedException

debugLog

public String debugLog()

Returns a DebugLog String.

Returns:

debug log