io.openems.backend.metadata.odoo.postgres.PeriodicWriteWorker

public class PeriodicWriteWorker extends Object

This worker combines writes to lastMessage and lastUpdate fields, to avoid DDOSing Odoo/Postgres by writing too often.

Constructor Details
- PeriodicWriteWorker
  
  public PeriodicWriteWorker(PostgresHandler parent)
Method Details
- start
  
  public void start()
  
  Starts the PeriodicWriteWorker.
- stop
  
  public void stop()
  
  Stops the PeriodicWriteWorker.
- onLastMessage
  
  public void onLastMessage(MyEdge edge)
  Called on
  
  invalid reference
  
  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 Set<Integer> drainToSet(LinkedBlockingQueue<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

Class PeriodicWriteWorker

Constructor Summary