Package io.openems.backend.alerting.handler

Class SumStateHandler

java.lang.Object

io.openems.backend.alerting.handler.SumStateHandler

All Implemented Interfaces:

Handler<SumStateMessage>

public class SumStateHandler
extends Object
implements Handler<SumStateMessage>

Constructor Summary

Constructors

Constructor	Description
SumStateHandler(MessageSchedulerService mss, TimedExecutor timeService, Mailer mailer, Metadata metadata, int initialDelay)

Method Summary

Modifier and Type	Method	Description
protected void	addOrUpdate(Edge edge, Level sumState)
protected SumStateMessage	getEdgeMessage(Edge edge, Level sumState)	Add Edge to list, with calculated TimeStamp (at which to notify).
Consumer<EventReader>	getEventHandler(String eventTopic)	Handle given event.
Class<SumStateMessage>	getGeneric()	Return generic type of handler as Class object.
void	send(ZonedDateTime sentAt, List<SumStateMessage> pack)	Send the messages.
void	stop()	Stop the Handler.
protected void	tryRemoveEdge(String edgeId)

Methods inherited from class java.lang.Object

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

Constructor Details

SumStateHandler

public SumStateHandler(MessageSchedulerService mss,
 TimedExecutor timeService,
 Mailer mailer,
 Metadata metadata,
 int initialDelay)

Method Details

stop

public void stop()

Description copied from interface: Handler

Stop the Handler.

Specified by:

stop in interface Handler<SumStateMessage>

send

public void send(ZonedDateTime sentAt,
 List<SumStateMessage> pack)

Description copied from interface: Handler

Send the messages.

Specified by:

send in interface Handler<SumStateMessage>

Parameters:

sentAt - TimeStamp at with sending was initiated

pack - which to send

getEdgeMessage

protected SumStateMessage getEdgeMessage(Edge edge,
 Level sumState)
                                  throws OpenemsException

Add Edge to list, with calculated TimeStamp (at which to notify).

Parameters:

edge - to add

sumState - of edge

Returns:

OfflineEdgeMessage generated from edge

Throws:

OpenemsException - on any error

tryRemoveEdge

protected void tryRemoveEdge(String edgeId)

addOrUpdate

protected void addOrUpdate(Edge edge,
 Level sumState)

getEventHandler

public Consumer<EventReader> getEventHandler(String eventTopic)

Description copied from interface: Handler

Handle given event.

Specified by:

getEventHandler in interface Handler<SumStateMessage>

Parameters:

eventTopic - to handle

Returns:

Consumer to be scheduled in executor

getGeneric

public Class<SumStateMessage> getGeneric()

Description copied from interface: Handler

Return generic type of handler as Class object.

Specified by:

getGeneric in interface Handler<SumStateMessage>

Returns:

GenericType of handler