PeriodicWriteWorker (OpenEMS Javadoc)

java.lang.Object
- io.openems.backend.metadata.odoo.postgres.PeriodicWriteWorker

```
public class PeriodicWriteWorker
extends java.lang.Object
```
This worker combines writes to lastMessage and lastUpdate fields, to avoid DDOSing Odoo/Postgres by writing too often.

Constructor Summary

Constructors
Constructor Description

PeriodicWriteWorker(PostgresHandler parent)

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`protected static java.util.Set<java.lang.Integer>`	`drainToSet(java.util.concurrent.LinkedBlockingQueue<java.lang.Integer> queue)`	Moves all entries of a `LinkedBlockingQueue` to a Set and clears the queue.
`void`	`onLastMessage(MyEdge edge)`	Called on `Edge.Events#ON_SET_LAST_MESSAGE_TIMESTAMP` event.
`void`	`onSetOnline(MyEdge edge, boolean isOnline)`	Called on `Edge.Events.ON_SET_ONLINE` event.
`void`	`onSetSumState(MyEdge edge, Level sumState)`	Called on `Edge.Events.ON_SET_SUM_STATE` event.
`void`	`start()`	Starts the `PeriodicWriteWorker`.
`void`	`stop()`	Stops the `PeriodicWriteWorker`.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - PeriodicWriteWorker
```
public PeriodicWriteWorker(PostgresHandler parent)
```
- Method Detail
  - start
```
public void start()
```
    Starts the PeriodicWriteWorker.
  - stop
```
public void stop()
```
    Stops the PeriodicWriteWorker.
  - onLastMessage
```
public void onLastMessage(MyEdge edge)
```
    Called on Edge.Events#ON_SET_LAST_MESSAGE_TIMESTAMP event.
    
    Parameters:
    
    edge - the MyEdge.
  - onSetOnline
```
public void onSetOnline(MyEdge edge,
                        boolean isOnline)
```
    Called on Edge.Events.ON_SET_ONLINE event.
    
    Parameters:
    
    edge - the MyEdge.
    
    isOnline - true if online, false if offline
  - onSetSumState
```
public void onSetSumState(MyEdge edge,
                          Level sumState)
```
    Called on Edge.Events.ON_SET_SUM_STATE event.
    
    Parameters:
    
    edge - the MyEdge.
    
    sumState - Sum-State Level
  - drainToSet
```
protected static java.util.Set<java.lang.Integer> drainToSet(java.util.concurrent.LinkedBlockingQueue<java.lang.Integer> queue)
```
    Moves all entries of a LinkedBlockingQueue to a Set and clears the queue. This is thread-safe.
    
    Parameters:
    
    queue - the LinkedBlockingQueue
    
    Returns:
    
    the Set