Package io.openems.backend.alerting.handler

Class OfflineEdgeHandler

java.lang.Object

io.openems.backend.alerting.handler.OfflineEdgeHandler

All Implemented Interfaces:

Handler<OfflineEdgeMessage>

public class OfflineEdgeHandler
extends java.lang.Object
implements Handler<OfflineEdgeMessage>

Field Summary

Fields

Modifier and Type	Field	Description
static int	MAX_SIMULTANEOUS_EDGES
static int	MAX_SIMULTANEOUS_MSGS

Constructor Summary

Constructors

Constructor	Description
OfflineEdgeHandler(MessageSchedulerService mss, Mailer mailer, Metadata metadata, int initialDelay)

Method Summary

Modifier and Type	Method	Description
protected OfflineEdgeMessage	getEdgeMessage(Edge edge)	Add Edge to list, with calculated TimeStamp (at which to notify).
java.lang.Runnable	getEventHandler(EventReader event)	Handle given event.
java.lang.Class<OfflineEdgeMessage>	getGeneric()	Return generic type of handler as Class object.
void	send(java.time.ZonedDateTime sentAt, java.util.List<OfflineEdgeMessage> pack)	Send the messages.
void	stop()	Stop the Handler.
protected void	tryAddEdge(Edge edge)
protected void	tryRemoveEdge(Edge edge)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_SIMULTANEOUS_MSGS

public static final int MAX_SIMULTANEOUS_MSGS

See Also:

Constant Field Values

MAX_SIMULTANEOUS_EDGES

public static final int MAX_SIMULTANEOUS_EDGES

See Also:

Constant Field Values

Constructor Detail

OfflineEdgeHandler

public OfflineEdgeHandler(MessageSchedulerService mss,
                          Mailer mailer,
                          Metadata metadata,
                          int initialDelay)

Method Detail

stop

public void stop()

Description copied from interface: Handler

Stop the Handler.

Specified by:

stop in interface Handler<OfflineEdgeMessage>

send

public void send(java.time.ZonedDateTime sentAt,
                 java.util.List<OfflineEdgeMessage> pack)

Description copied from interface: Handler

Send the messages.

Specified by:

send in interface Handler<OfflineEdgeMessage>

Parameters:

sentAt - TimeStamp at with sending was initiated

pack - which to send

getEdgeMessage

protected OfflineEdgeMessage getEdgeMessage(Edge edge)

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

Parameters:

edge - to add

Returns:

OfflineEdgeMessage generated from edge

tryRemoveEdge

protected void tryRemoveEdge(Edge edge)

tryAddEdge

protected void tryAddEdge(Edge edge)

getEventHandler

public java.lang.Runnable getEventHandler(EventReader event)

Description copied from interface: Handler

Handle given event.

Specified by:

getEventHandler in interface Handler<OfflineEdgeMessage>

Parameters:

event - to handle

Returns:

Runnable to be scheduled in executor

getGeneric

public java.lang.Class<OfflineEdgeMessage> getGeneric()

Description copied from interface: Handler

Return generic type of handler as Class object.

Specified by:

getGeneric in interface Handler<OfflineEdgeMessage>

Returns:

GenericType of handler